Google GitGoogle Git
Sign in
apache/flink-connector-aws/HEAD
  1. 2fc634d [FLINK-35500] Build DELETE key from primary key for CDC deletes by riyarawat-amazon · 5 weeks ago main
  2. 75a4142 [FLINK-39137] Add configurable interval between non-empty `getRecords` calls by Andreas Bube · 5 weeks ago
  3. 6787a1d [FLINK-40184] Remove `DescribeStream` inconsistency-resolution check from shard discovery by riyarawat-amazon · 3 months ago
  4. 957f7eb [FLINK-40065] Update `flink-connector-parent` to 2.0.0 and Flink to 2.1.2 by Purushottam Sinha · 3 months ago
  5. e17153c [hotfix] Update project version to 6.1-SNAPSHOT by Ferenc Csaky · 4 months ago
  6. 11fcabf [FLINK-27941] Migrate remaining tests to JUnit5 by jlalwani-amazon · 4 months ago
  7. da3b970 [FLINK-39106] Support `ROW` and `ARRAY<ROW>` data types in DynamoDB API / SQL sink by ddebowczyk92 · 4 months ago
  8. ede02da [FLINK-39660] Fix Netty event loop threads blocking and race condition in `FanOutKinesisShardSubscription` by chenylee-aws · 5 months ago
  9. efa469f [INFRA] Set up default protection ruleset for default and release branches by The Apache Software Foundation · 5 months ago
  10. c662ddd [FLINK-39540][Connectors/Kinesis][6.x] Addressed bugs for EFO subscriptions when they are completed (#243) by pelaezryan · 5 months ago
  11. aaf3123 [hotfix][docs] Fix `kinesis.md` syntax error and update `kinesis.yml` by Ferenc Csaky · 8 months ago
  12. dce6c76 [hotfix][docs] Update doc version by Ferenc Csaky · 8 months ago
  13. d704c0a [hotfix] Include missing license headers for SRC files by Ferenc Csaky · 8 months ago
  14. 19c8406 [hotfix] Update releasing submodule by Ferenc Csaky · 8 months ago
  15. aafad9b [hotfix] Fix AWS SDK version in NOTICE files by Ferenc Csaky · 9 months ago
  16. 2a9620b [FLINK-38952] Update PyFlink connector classes to match with the current Java API and entities by Abhi Gupta · 9 months ago
  17. 7cfbe5e [hotfix] Turn back Python CI by Ferenc Csaky · 9 months ago
  18. 976e0e8 [hotfix] Update NOTICE dates to 2026 by Ferenc Csaky · 9 months ago
  19. c2a557d [hotfix] Update project version to 6.0-SNAPSHOT by Ferenc Csaky · 9 months ago
  20. 03e2fad [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss by Arun Lakshman · 1 year, 6 months ago
  21. 68acdbd [FLINK-36296] Add support for incremental shard discovery for DynamoDB Streams Source by Abhi Gupta · 10 months ago
  22. 373be6f [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws by Hong Liang Teoh · 1 year, 4 months ago
  23. acd6992 [FLINK-37866] Migrate glue schema registry e2e test to use aws-kinesis-streams connector by Daren · 1 year, 4 months ago
  24. d22078f [FLINK-36770] make AWS sink writers use ResultHandler, move flink version to 1.20 by Ahmed Hamdy · 1 year, 10 months ago
  25. 9d6746b [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing throttling by Keith Lee · 1 year, 6 months ago
  26. ca96d84 [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator by gguptp · 1 year, 7 months ago
  27. 8b09b33 [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls for DDB connector by gguptp · 1 year, 8 months ago
  28. b55dec1 [FLINK-36668][build] Update AWS build for v5.0 by Hong Teoh · 1 year, 11 months ago
  29. 3abc1c5 [FLINK-31989][docs] Update english docs for Kinesis Table API by Hong Teoh · 1 year, 11 months ago
  30. 163a475 [FLINK-31989][docs] Update english docs for DynamoDbStreamsSource by Hong Teoh · 1 year, 11 months ago
  31. a2db76b [FLINK-31989][docs] Update english docs for KinesisStreamsSource by Hong Teoh · 1 year, 11 months ago
  32. e0e1b30 [hotfix] Update NOTICE files to reflect the packaged dependencies by Hong Teoh · 1 year, 11 months ago
  33. c97f93d [FLINK-35401] Add Sqs Table API connector by Ahmed Hamdy · 2 years, 2 months ago
  34. da74232 [FLINK-31980][Connectors/Kinesis] Implement EFO subscription by Hong Teoh · 2 years, 1 month ago
  35. 4f12c86 [FLINK-31980][Connectors/Kinesis] Abstract away base SplitReader logic from PollingKinesisShardSplitReader to set up for FanOutKinesisShardSplitReader by Hong Teoh · 2 years, 1 month ago
  36. 30d32fd [FLINK-36637] Fix ListShards for Kinesis streams with large number of shards by Elphas Toringepi · 2 years ago
  37. b922a2d [FLINK-31987][Connectors/AWS] Implement KDS Table API support by Burak Ozakinci · 2 years ago
  38. c057031 [FLINK-36428][Connectors/DynamoDB] DynamoDb Table API Sink fails when null value in the RowData by maoxd · 2 years, 2 months ago
  39. 52870f1 [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB connector by gguptp · 2 years ago
  40. 6e83eac [FLINK-36519][docs] replace accept with apply by Jorick Caberio · 2 years ago
  41. 426720f Bump org.apache.avro:avro from 1.11.3 to 1.11.4 by dependabot[bot] · 2 years ago
  42. 91381cd [FLINK-36427] Multiple shard IT cases for KDS source by Elphas Toringepi · 2 years ago
  43. b681cfc [FLINK-31986][Connectors/Kinesis] Setup integration tests for source by Elphas Toringepi · 2 years ago
  44. 7fbca55 [FLINK-36357][Connectors/Kinesis] Set up AWS SDK default retry strategy configurations by Hong Teoh · 2 years ago
  45. c525e9a [FLINK-36329][Connectors/DynamoDB] Changing retry strategy to use SDK retries to catch all retryable exceptions by gguptp · 2 years, 1 month ago
  46. 4d4f04b Bump com.google.protobuf:protobuf-java from 3.21.7 to 3.25.5 by dependabot[bot] · 2 years, 1 month ago
  47. 3a0e4f5 [FLINK-36328][Connectors/DynamoDB] Making the child split not found as a debug log instead of warn by gguptp · 2 years, 1 month ago
  48. 22f154b [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff by Burak Ozakinci · 2 years, 1 month ago
  49. 9b0d983 [FLINK-36270][Connectors/DynamoDB] Assign only children splits of a split when it is marked as finished by gguptp · 2 years, 1 month ago
  50. 5d2deb1 [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161) by Joern Kottmann · 2 years, 1 month ago
  51. 876892d [FLINK-36239][Connectors/DynamoDB][BugFix] Making the shard retention period to 48h instead of 24h by gguptp · 2 years, 1 month ago
  52. baef427 [FLINK-36229][Connectors/AWS] Port SingleThreadMultiplexSourceReaderBase to new undeprecated interfaces by Hong Teoh · 2 years, 1 month ago
  53. 41f6710 [FLINK-36187][Connectors/Kinesis] Implement UniformShardAssigner using Kinesis shard hashes in the KinesisStreamsSource by Hong Teoh · 2 years, 1 month ago
  54. 4604d66 [FLINK-36206][Connectors/AWS] Adding support for custom override configuration by gguptp · 2 years, 1 month ago
  55. 4d847fe [FLINK-36215][dynamodb][BugFix] Removing dependency on ordering of splits by gguptp · 2 years, 1 month ago
  56. 18ff2d2 [FLINK-35660][dynamodb] Adding parent-child shard ordering for DDB Streams source and add MillisBehindLatest metric by gguptp · 2 years, 3 months ago
  57. cc0b4d4 [FLINK-35305][Connector/SQS] Amazon SQS Sink Connector by Priya Dhingra · 2 years, 5 months ago
  58. 5f138ab [hotfix][ci] Update ci to include 1.20.0 by Aleksandr Pilipenko · 2 years, 2 months ago
  59. 55ba5ac [hotfix][Connectors/AWS] Bump default Flink version to minimum support version, 1.19.0 by Hong Teoh · 2 years, 2 months ago
  60. 6cfa13d [FLINK-35815][Connector/Kinesis] Fix detection of recoverable exceptions for EFO operations by Aleksandr Pilipenko · 2 years, 2 months ago
  61. 4258ec4 [FLINK-35819][Connectors/AWS] Update to AWS SDKv2 2.26.19 by Burak Ozakinci · 2 years, 3 months ago
  62. f81473e [FLINK-32324][Connectors/AWS] Implement support for watermark alignment in FLIP-27 sources for KDS and DDB streams by Aleksandr Pilipenko · 2 years, 3 months ago
  63. c716ca4 [FLINK-32218][Connector/Kinesis] Add support for parent-child shard ordering by Aleksandr Pilipenko · 2 years, 3 months ago
  64. 4fc3597 [hotfix][ci] Update builds to test against 1.19.1 by Hong Teoh · 2 years, 3 months ago
  65. 7f3483c [FLINK-34341] Initial implementation of DynamoDBStreams Source. Marked as Experimental by Abhi Gupta · 2 years, 4 months ago
  66. 36479a9 [FLINK-35022][Connectors/DynamoDB] Add Default DynamoDB Element Converter by Ahmed Hamdy · 2 years, 6 months ago
  67. 9a610a2 [FLINK-35705][Connector/Kinesis] Use region from stream ARN to create Kinesis client by Aleksandr Pilipenko · 2 years, 3 months ago
  68. 9e418f7 [FLINK-32229][Connector/Kinesis] Add millisBehindLatest metric to Kinesis source implementation by Burak Ozakinci · 2 years, 4 months ago
  69. 20e4ee6 [FLINK-35559][Connector/Kinesis] fix shading configuration to avoid class conflicts when using flink-connector-kinesis alongside Firehose sink by Aleksandr Pilipenko · 2 years, 4 months ago
  70. 0684555 [FLINK-35132][Connectors/AWS] Update website data for 4.4-SNAPSHOT by Danny Cranmer · 2 years, 4 months ago
  71. fbd13c2 [FLINK-35132][Connectors/AWS] Bump development version to 4.4-SNAPSHOT by Danny Cranmer · 2 years, 4 months ago
  72. c688a85 [FLINK-35269] Log information about failed records as warnings instead of debug for Kinesis and Firehose sinks by Aleksandr Pilipenko · 2 years, 5 months ago
  73. c6e0abb [FLINK-33506][Connectors/AWS] Add support for jdk17 for AWS connectors (#115) by Sergey Nuyanzin · 2 years, 6 months ago
  74. 8d29147 [FLINK-35115][Connectors/Kinesis] Allow kinesis consumer to snapshotState after cancelling operator by Aleksandr Pilipenko · 2 years, 6 months ago
  75. dcf0068 [hotfix][Connectors/AWS] Bump default Flink version to minimum support version, 1.18.0 by Danny Cranmer · 2 years, 6 months ago
  76. 6717cba [FLINK-35113][Connectors/AWS] Bump commons-compress and commons-io dependency versions by Danny Cranmer · 2 years, 6 months ago
  77. 8cafbbc [FLINK-30388] Move Lazy Initialization of AWS element converters to SinkWriter open() method by Ahmed Hamdy · 2 years, 6 months ago
  78. 35be16b [FLINK-34044][Connectors/Kinesis] Copy dynamic table options before mapping deprecated configs (#132) by Ahmed Hamdy · 2 years, 7 months ago
  79. 6286160 [hotfix][Connectors/AWS] Update Flink versions in CI by Aleksandr Pilipenko · 2 years, 7 months ago
  80. e8ba71e [FLINK-34892][ci] Fix python test failure due to config file change by Aleksandr Pilipenko · 2 years, 7 months ago
  81. b512749 [hotfix] Add IssueNavigationLink in Intellij VCS config by Aleksandr Pilipenko · 2 years, 8 months ago
  82. 5e1d76d [FLINK-32964][Connectors/AWS] Ensure that new instance of DefaultCredentialsProvider is created for each client by Aleksandr Pilipenko · 2 years, 8 months ago
  83. 5b6f087 [FLINK-34260][Connectors/AWS] Update flink-connector-aws to be compatible with updated SinkV2 interfaces by Aleksandr Pilipenko · 2 years, 8 months ago
  84. b207606 [FLINK-34407][Connectors/Kinesis] Fix unstable test by Aleksandr Pilipenko · 2 years, 8 months ago
  85. 05fdf37 [hotfix] Update copyright year to 2024 by gongzhongqiang · 2 years, 8 months ago
  86. 38aafb4 [FLINK-34017][docs] Connectors docs with 404 link in dynamodb.md (#124) by gongzhongqiang · 2 years, 9 months ago
  87. b7f2e26 [FLINK-33560][Connectors/AWS] Externalize AWS Python connectors from Flink to AWS project by Danny Cranmer · 2 years, 10 months ago
  88. 27db878 [hotfix][Connectors/AWS] Bumping default Flink version in source to 1.17.0 by Danny Cranmer · 2 years, 10 months ago
  89. 0f5bec5 [hotfix][Connectors/AWS] Promoting to 4.3-SNAPSHOT by Danny Cranmer · 2 years, 10 months ago
  90. ebf606e [hotfix][docs] Fix identifier collision causing coflict when switching between tabs in kinesis connector docs by Aleksandr Pilipenko · 2 years, 11 months ago
  91. 4c2fdd9 [FLINK-33260][Connectors/Kinesis] Allow user to provide a list of recoverable exceptions (#110) by Emre Kartoglu · 3 years ago
  92. 0243540 [hotfix][Connectors/AWS] Update Flink versions in CI by Danny Cranmer · 3 years ago
  93. b2e82b7 [hotfix][Connectors/DynamoDB] Fix flink-connector-aws-base version by Danny Cranmer · 3 years ago
  94. 3f4d59b [FLINK-33413][Connectors/AWS] Bump Avro version in AWS Connectors by Danny Cranmer · 3 years ago
  95. 23624ab [FLINK-33409][Connectors/AWS] Bump Guava in AWS Connectors to to 32.1.3-jre by Danny Cranmer · 3 years ago
  96. c244bb3 [FLINK-33194][Connectors/Kinesis] Remove dependency on Flink Shaded by Jiabao Sun · 3 years ago
  97. bb71f97 [FLINK-32230][Connectors/AWS] Update AWS SDKv2 to v2.20.144 by Antonio Vespoli · 3 years ago
  98. 76d791f [FLINK-33181][Connectors/Kinesis] Not validate source & sink options when creating dynamic tables (#105) by Khanh Vu · 3 years ago
  99. c3395b7 [FLINK-33279][Connector/Kinesis] Skip AWS e2e tests run if credentials not present by Aleksandr Pilipenko · 3 years ago
  100. 3b4d91d [hotfix][Connectors/AWS] Fix flink-connector-base dependency issue by Danny Cranmer · 3 years ago