aws-samples amazon-kinesis-data-analytics-examples issues

aws-samples / amazon-kinesis-data-analytics-examples

Example applications in Java, Python and SQL for Kinesis Data Analytics, demonstrating sources, sinks, and operators.

MIT No Attribution

139 stars 87 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Add deprecation notes and more links to new repo

#82 nicusX closed 6 months ago
0
preserve Service provider interface when building scala uber jars

#81 munkyboy opened 10 months ago
0
scala examples do not work for packaging applications which use the TableAPI

#80 munkyboy opened 10 months ago
0
Adding all properties that user has defined.

#79 akshayar closed 1 year ago
1
Kafka example at https://docs.aws.amazon.com/managed-flink/latest/java/example-msk.html is not working

#78 akshayar opened 1 year ago
0
Amazon Managed Service for Apache Flink rebrand

#77 nicusX closed 1 year ago
0
Migrating CloudWatchSink example to use Async Sink

#76 dannycranmer closed 1 year ago
0
Bump semver from 6.3.0 to 6.3.1 in /ScheduledScaling/scheduled-scaling-cdk

#75 dependabot[bot] opened 1 year ago
0
fixing git ignore

#74 FranMorilloAWS opened 1 year ago
0
Bump aws-cdk-lib from 2.64.0 to 2.80.0 in /ScheduledScaling/scheduled-scaling-cdk

#73 dependabot[bot] opened 1 year ago
0
Fixed Source link to point to correct repo

#72 sacthakk closed 1 year ago
0
KDA-UDF-Sample

#71 sacthakk closed 1 year ago
0
Flip format from CSV to JSON to bypass Flink issue FLINK-28513

#70 dannycranmer closed 1 year ago
0
Added Open Source License File and added Pytorch property in process window function

#69 jeremyber-aws opened 1 year ago
0
Adding Image Classification Example using DJL Framework (http://djl.ai/)

#68 jeremyber-aws closed 1 year ago
0
Add Apache Flink StateFun runtime example

#67 awsalialem closed 1 year ago
0
Delta-flink multicluster writes

#66 jyusov closed 1 year ago
0
[HotFix] Corrected main class entry point

#65 darenwkt closed 1 year ago
0
Rajdban feature kda sql to kda studio

#64 rajdban closed 1 year ago
0
converting KDA-SQL to KDA-Studio

#63 rajdban closed 1 year ago
2
Delta flink example

#62 jyusov closed 1 year ago
0
Couldn't deploy python getting started example

#61 rosumaraioana closed 1 year ago
4
Switch Beam examples to new KinesisIO API

#60 psolomin closed 1 year ago
0
Beam examples use deprecated IO API

#59 psolomin closed 1 year ago
1
Add anomaly detection example using Random Cut Forest library

#58 z3d1k closed 1 year ago
0
Add anomaly detection example

#57 antovespoli closed 1 year ago
1
scheduled scaling cdk

#56 FranMorilloAWS closed 1 year ago
1
KDS-GSR-KDA

#55 FranMorilloAWS closed 1 year ago
1
Kda_Demo

#54 bibhu107 closed 1 year ago
0
Example of AVRO + Glue Schema Registry with Kafka source and sink

#53 nicusX closed 1 year ago
1
Bump log4j-core from 2.12.1 to 2.17.1 in /CustomKeystoreWithConfigProviders

#52 dependabot[bot] closed 1 year ago
0
Added CustomKeystoreWithConfigProviders

#51 karthitect closed 1 year ago
0
java.io.NotSerializableException: Non-serializable lambda

#50 GregoryKueski opened 1 year ago
0
Scala NoSuchMethodError: 'scala.collection.mutable.Buffer (and all other Scala packages)

#49 GensaGames closed 1 year ago
1
[FLINK-29205]: Kinesis connector was upgraded and contains the fix from FLINK-29205

#48 astamur closed 1 year ago
0
Python firehose sink sample application

#47 babakc closed 1 year ago
0
Update getting-started.py

#46 babakc closed 1 year ago
0
As long as java 11 or above, then fine

#45 yezhengli-Mr9 closed 1 year ago
0
Added scheduled scaling sample

#44 karthitect closed 1 year ago
0
Update Custom Keystore example to use the latest Kafka connectors APIs

#43 antovespoli closed 2 years ago
0
Python examples: please clarify which kinesis connector JAR should be used

#42 mattfysh opened 2 years ago
1
Add the project for downloading JARs in runtime

#41 awsalialem closed 2 years ago
2
Flink 1 15 changes

#40 astamur closed 2 years ago
0
Revert "Flink 1 15 changes"

#39 karthitect closed 2 years ago
0
Revert event enrichment code

#38 srakshit closed 2 years ago
0
Flink 1 15 changes

#37 astamur closed 2 years ago
0
Update README to include guidance on dependency management

#36 karthitect closed 2 years ago
0
Bump gson from 2.8.6 to 2.8.9 in /EventEnrichment

#35 dependabot[bot] closed 2 years ago
0
Bump aws-java-sdk-s3 from 1.12.162 to 1.12.261 in /EventEnrichment

#34 dependabot[bot] closed 2 years ago
0
adding kafka tumbling window example

#33 jeremyber-aws closed 2 years ago
0