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