You can then execute the Beam pipeline with Amazon Kinesis Data Analytics in a fully managed Apache Flink environment. A Kinesis Analytics application basically consists of a reference to the Flink application in Amazon S3 and some additional configuration data. Once the Kinesis Data Analytics application has been created, it can be deployed and executed by the services in a fully managed environment.
Navigate to the Kinesis Data Analytics Console and press Create application
beam-workshop as the Application name
Select Apache Flink 1.8 as the Runtime.
Choose Choose from IAM roles that Kinesis Kinesis Analytics can assume as Access permissions. If you are attending an AWS hosted event, select the only role that is suggested. If you are running the workshop on your own, select the role that contains
Create the application by pressing the blue Create Application button. This will take you to the overview screen where you will configure further properties of the application.