Amazon Kinesis Data Analytics Studio - Quickly Interact with Streaming Data Using SQL, Python,Scala

[@darkprash6691]

Hello. Thanks for the amazing video. I have been getting an error "org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table "hive.XXXX" while inserting into "sensor_state". Any clue? Not able to find any help online. Thanks.

[@Amarjeet-fb3lk]

Hi Soumil, I have a question. If you are defining your stream in the sql query where you want to put the aggregated data,then why are you creating the table sensor_state, and inserting into that. Isn’t that part at 11.39 , defining the table and the output stream where it should write the data. Why we have another insert statement for sensor_state table?

[@sagnikmukherjee5108]

Thanks for the awesome tutorial, buddy. I am able to create the streaming pipeline end to end.

[@SoumilShah]

Great!

[@nehalverma1444]

Thankyou!

[@sohailpagdiwale7146]

while im running thie on my editor it showing me an error= kinesis_client = boto3.client('kinesis', NameError: name 'boto3' is not defined can you help me to resolve this error ?

[@SoumilShah]

Pip install boto3