You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In the AWS documentation however, the JAR mentioned is flink-sql-connector-kinesis_2.12-1.13.1.jar in places, and also the 1.13.2 version within the same article
flink-sql-connector-kinesis_2.12-1.13.x.jar: use this connector if you're planning to deploy it as a Flink 1.13 application (AWS documentation is correct)
amazon-kinesis-connector-flink connector is used for Flink 1.8 and 1.11 for DataStreamAPI, but python apps use TableAPI
amazon-kinesis-sql-connector is used for TableAPI in Flink 1.8 and 1.11
This versions should be used on today:
In this codebase, the JAR listed in several application properties for python examples is one of:
amazon-kinesis-connector-flink-2.0.0.jar
flink-sql-connector-kinesis_2.12-1.13.2.jar
amazon-kinesis-sql-connector-flink-2.0.3.jar
For example: https://github.com/aws-samples/amazon-kinesis-data-analytics-examples/blob/master/python/S3Sink/application_properties.json
In the AWS documentation however, the JAR mentioned is
flink-sql-connector-kinesis_2.12-1.13.1.jar
in places, and also the1.13.2
version within the same articleLocated here: https://docs.aws.amazon.com/kinesisanalytics/latest/java/gs-python-createapp.html
Please clarify which of these dependencies should be included in the uploaded ZIP file
The text was updated successfully, but these errors were encountered: