issues
search
aws-samples
/
amazon-managed-service-for-apache-flink-examples
Collection of code examples for Amazon Managed Service for Apache Flink
MIT No Attribution
39
stars
20
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Custom TypeInfo example
#71
nicusX
closed
1 hour ago
1
Comment-out ssl.truststore.location from Kafka connector examples
#70
nicusX
opened
2 weeks ago
0
Bump org.apache.avro:avro from 1.10.2 to 1.11.4 in /java/IcebergDatastreamSink
#69
dependabot[bot]
closed
2 weeks ago
1
Extend contributing instructions and pull request template
#68
nicusX
closed
2 weeks ago
2
Update Iceberg example
#67
nicusX
closed
2 weeks ago
0
Fix provided dependencies in all Java examples
#66
nicusX
closed
3 weeks ago
1
Modify dependency scopes for consistency and to minimize the uber JAR size
#65
nicusX
closed
3 weeks ago
0
Update KDS example to use new connector api
#64
guanlin84
closed
3 weeks ago
2
Java Examples for Exception Handling including Async IO and Side Ouputs
#63
alexiteki
opened
4 weeks ago
0
Modified Scala Getting Started example to work both locally and on MSF
#62
nicusX
closed
3 weeks ago
1
Reduce data generation frequency to avoid throttling from Bedrock
#61
nicusX
closed
1 month ago
0
Fix Scala Getting Started README
#60
nicusX
closed
1 month ago
0
Improve READMEs consistency
#59
nicusX
closed
1 month ago
0
Update examples to 1.20
#58
antovespoli
closed
1 month ago
0
Update examples to Flink 1.20
#57
antovespoli
closed
1 month ago
0
MSK SASL/SCRAM using Config Providers
#56
nicusX
closed
1 month ago
2
Minor updates of general READMEs
#55
nicusX
closed
2 months ago
0
Example using Apache Beam Python SDK
#54
Meosit
closed
2 months ago
1
Update Kafka Custom Keystore with Config Providers example
#53
nicusX
closed
2 months ago
0
Python dependencies example
#52
nicusX
closed
2 months ago
0
s3sink permission issues (org.apache.hadoop.fs.s3a.impl.MultiObjectDeleteSupport.translateDeleteException)
#51
cazter
closed
2 months ago
1
Modified Python UDF Sample to use dependencies via requirements.txt
#50
jeremyber-aws
closed
2 months ago
1
Update to Flink 1.19
#49
nicusX
closed
4 months ago
3
How about stream sink hudi example?
#48
LeeYaChao
opened
4 months ago
0
Issue running java/GettingStarted project.
#47
waltmayfield
closed
5 months ago
1
Does MSF support specify core-site.xml or flink-conf.yaml directly while compiling jar package?
#46
guanlinz
closed
2 months ago
1
Version upgrade
#45
nuno-c-afonso
closed
7 months ago
0
Redesigned the GettingStartedTable
#44
nicusX
closed
7 months ago
0
Remove Quotes from jaas config in Kafka Connector IAM
#43
jeremyber-aws
opened
8 months ago
0
Adding CW Dashboard
#42
jeremyber-aws
closed
8 months ago
0
restricting policies and adding more metrics
#41
FranMorilloAWS
closed
9 months ago
0
fixed open policies
#40
FranMorilloAWS
closed
9 months ago
0
updated iceberg sink
#39
FranMorilloAWS
closed
10 months ago
0
AutoScaling example parameters changes
#38
FranMorilloAWS
closed
10 months ago
0
Scaling updated
#37
FranMorilloAWS
closed
10 months ago
0
improving scaling solution
#36
FranMorilloAWS
closed
10 months ago
0
Fix missing local dependency in KafkaConfigProviders example
#35
nicusX
closed
11 months ago
0
Fix typos in Python local dockerized environment instructions
#34
nicusX
closed
1 year ago
0
Dockerized local development for PyFlink on Apple Silicon macOS machines
#33
nicusX
closed
1 year ago
0
Well-Architected Lens
#32
jeremyber-aws
opened
1 year ago
1
autoscaling
#31
FranMorilloAWS
closed
1 year ago
0
S3 parquet sink cloudformation
#30
akshayar
closed
1 year ago
1
S3Sink example modified with cloudformation template
#29
akshayar
closed
1 year ago
1
Cloudformation templates for Kinesis connector , Kafka connector and windowing examples
#28
akshayar
closed
1 year ago
1
Bump Flink dependency to 1.15.4
#27
nicusX
closed
1 year ago
0
Bump org.apache.avro:avro from 1.10.2 to 1.11.3 in /java/IcebergDatastreamSink
#26
dependabot[bot]
closed
1 year ago
1
Bump org.apache.avro:avro from 1.9.2 to 1.11.3 in /java/S3ParquetSink
#25
dependabot[bot]
closed
1 year ago
1
Bump org.apache.avro:avro from 1.10.2 to 1.11.3 in /java/AvroGlueSchemaRegistryKafka
#24
dependabot[bot]
closed
1 year ago
1
Bump org.apache.avro:avro from 1.10.2 to 1.11.3 in /java/AvroGlueSchemaRegistryKinesis
#23
dependabot[bot]
closed
1 year ago
1
Custommetrics
#22
srakshit
closed
1 year ago
0
Next