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