amazon-kinesis-data-analytics-flink-starter-kit
amazon-kinesis-data-analytics-flink-starter-kit copied to clipboard
aws-samples
Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window...
I want to use glue catalog in flink. but val hiveCatalogSql = s""" |CREATE CATALOG hive_catalog WITH ( | 'type' = 'hive', | 'default-database' = 'prod_ods', | 'hive-conf-dir' = '/usr/lib/hive/conf'...
*Issue #, if available:* *Description of changes:* Updating Java Runtime and the Jar name in the `flink_starter_kit_def_stream_position_trim_horizon.json` file Issue was related to https://stackoverflow.com/questions/58125830/has-been-compiled-by-a-more-recent-version-of-the-java-runtime-class-file-versi Logs: ``` { "applicationARN": "arn:aws:kinesisanalytics:us-east-1::application/amazon_kda_flink_starter_kit", "applicationVersionId": 1,...
*Issue #, if available:* *Description of changes:* Updated runtime property name in readme to match name in code. Correct name in context: https://github.com/aws-samples/amazon-kinesis-data-analytics-flink-starter-kit/blob/7e70b7225b4ab76872818f3979ec48246fb20937/src/main/java/com/amazonaws/kda/flink/starterkit/SessionProcessor.java#L118 If set incorrectly, this breaks the app...
Metadata
Owner
Metadata
Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window...