Google Git
Sign in
apache / flink-connector-aws / HEAD
  1. 9743a29 [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisStreamsSink by Hong Liang Teoh · 3 weeks ago main
  2. 5990edd Bump org.xerial.snappy:snappy-java from 1.1.10.1 to 1.1.10.4 by dependabot[bot] · 6 days ago
  3. b996d1d [FLINK-24943][Connectors / Kinesis] Explicitly create KryoSerializer for SequenceNumber class in Kinesis Consumer by Alexander Egorov · 3 weeks ago
  4. 8b0ae0f [hotfix] Remove dependency on shaded guava to reduce refactoring needed for Flink version upgrades by Hong Liang Teoh · 5 weeks ago
  5. 82394be [hotfix] Add MiniClusterExtension to ITCase tests by Hong Liang Teoh · 5 weeks ago
  6. 21c64ce [hotfix][Connectors/Kinesis] Fixed typo in the Kinesis connector documentation by MRKKmrkk · 9 weeks ago
  7. fa0e68f [hotfix][docs] Remove old reference to licensing issue from docs since this was resolve in Flink 1.10.0 by Danny Cranmer · 9 weeks ago
  8. 29c4828 [FLINK-32595][Connectors/Kinesis] Fix the deserialization schema version in the datastream conneter doc by Yuxin Tan · 3 months ago
  9. 63ceb4f [FLINK-31662][connectors][aws] Restructure repository to account for flink-formats-aws by Hong Liang Teoh · 3 months ago
  10. 6484f9d [FLINK-32208] Adding managed flink-connector-base to fix convergence issue. Remove DDB dependency on Guava by Danny Cranmer · 3 months ago
  11. 6cacefe [FLINK-32208] Remove dependency on flink-shaded from flink-connector-aws by Sergey Nuyanzin · 4 months ago
  12. 9983073 [FLINK-32500][Connectors/AWS] Update dependency versions for guava and snappy-java by Aleksandr Pilipenko · 3 months ago
  13. 16b0236 [FLINK-29443] Replicate packaging tests by darenwkt · 9 months ago
  14. 3c127ba [FLINK-32372] Push PR support build and test with recently release flink version 1.16.2 and 1.17.1 by Samrat002 · 4 months ago
  15. 1006e6a [FLINK-31990][Connectors/Kinesis] Use Configuration object instead of properties in KDS Source by Hong Liang Teoh · 4 months ago
  16. d1a3f63 Revert "[hotfix] Sync CI workflow against other ASF Flink externalized connectors" by Martijn Visser · 4 months ago
  17. 93d96be Revert "[FLINK-31923] Run nightly builds against multiple branches and Flink versions" by Martijn Visser · 4 months ago
  18. 0621f7a [FLINK-31923] Run nightly builds against multiple branches and Flink versions by Martijn Visser · 4 months ago
  19. 31eda54 [hotfix] Sync CI workflow against other ASF Flink externalized connectors by Martijn Visser · 4 months ago
  20. 43e1295 [FLINK-24438][Connectors/Kinesis] Implement FLIP-27 based Kinesis Source by Hong Liang Teoh · 6 months ago
  21. 0be8192 [FLINK-31772][Connector/Kinesis] Adjusting Kinesis Ratelimiting strategy to fix performance regression (#70) by Ahmed Hamdy · 5 months ago
  22. 4ec9d4f [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml by Weijie Guo · 5 months ago
  23. 3e1fcca [hotfix] Python connector download link should refer to the url defined in externalized repository by Weijie Guo · 5 months ago
  24. bb9e839 [hotfix] Update the version in docs to 4.1.0 by Weijie Guo · 5 months ago
  25. a62e3d8 [FLINK-31108][Connectors/Kinesis] Use Stream ARN instead of Stream Name for Kinesis API calls by Hong Liang Teoh · 5 months ago
  26. 9a51b52 [FLINK-31675][Connectors/AWS] Update AWS SDKv2 to v2.20.32 for 4.x (#68) by antovespoli · 5 months ago
  27. 17820d0 [FLINK-22828][Connectors/AWS] Update docs by Emre Kartoglu · 5 months ago
  28. 4e230fb [FLINK-22828][Connectors/AWS] Configure custom AWS creds provider by Emre Kartoglu · 6 months ago
  29. 410fe4b Update version to 4.2-SNAPSHOT by Danny Cranmer · 6 months ago
  30. ef6ec5e [hotfix] Add missing copyright headers by Danny Cranmer · 6 months ago
  31. 1c9e049 [hotfix][ci] Update Flink versions in CI builds by Aleksandr Pilipenko · 6 months ago
  32. d166ee2 [FLINK-31492][Connectors/AWS] Add support for exception classification based on AWS error codes by Samuel Siebenmann · 6 months ago
  33. 05458d9 [hotfix][Connectors/AWS] Update current year in NOTICE files by Danny Cranmer · 6 months ago
  34. 72a78e6 [FLINK-16003][Connectors/Kinesis] Log non-retriable Kinesis exceptions from getRecords by Emre Kartoglu · 7 months ago
  35. 930d196 [FLINK-30229][Connectors/DynamoDB] Add SQL IT case for DynamoDB Sink (#42) by darenwkt · 7 months ago
  36. fdfe982 [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail to stop gracefully during stop-with-savepoint by Danny Cranmer · 7 months ago
  37. 98cde3d [FLINK-30947][Formats/AWS] Externalize and configure E2E test for JSON Glue Schema Registry format by Hong Liang Teoh · 8 months ago
  38. 374b45f [FLINK-30947][Formats/AWS] Externalize and configure E2E test for Avro Glue Schema Registry format by Hong Liang Teoh · 8 months ago
  39. 7477266 [FLINK-30777][Connectors/Kinesis]Allow Kinesis Table API Connector to specify shard assigner by karthitect · 8 months ago
  40. bc8b28b [hotfix] Fix dead link in e2e-test module's README.md. by Weijie Guo · 8 months ago
  41. e0ac364 [hotfix][Connectors/AWS] fix typo in pull request template by Hong Liang Teoh · 8 months ago
  42. 826413b [hotfix][ci] Update Flink version in CI workflow to 1.16.1 (#53) by Aleksandr Pilipenko · 8 months ago
  43. 639ab72 [FLINK-30806][Connectors/Kinesis] Bump protobuf-java dependency version to 3.21.7 (#51) by Aleksandr Pilipenko · 8 months ago
  44. 81c175e [FLINK-30783][Connectors/AWS] Add a pull request template by Hong Liang Teoh · 8 months ago
  45. e5f1362 [FLINK-30762][ci] Add nightly build workflow by Aleksandr Pilipenko · 8 months ago
  46. 68c3caa [FLINK-30378][docs] Use modified sql_connector_download_table shortcode by Chesnay Schepler · 9 months ago
  47. 70c84cb [FLINK-30418] [Connectors/Kinesis] Implement synchronous KinesisClient in EFO by darenwkt · 9 months ago
  48. 2a24e7c [FLINK-30633][Connectors/AWS] Update AWS SDKv2 to v2.19.14 and Netty to 4.1.86.Final by Danny Cranmer · 9 months ago
  49. 79e0a49 [FLINK-30633][Connectors/AWS] Normalize NOTICE files and fix issues by Danny Cranmer · 9 months ago
  50. 9ee0fe3 [FLINK-30224][Connectors/Kinesis] Added an IT test for slow FlinKinesisConsumer's run which caused NPE in close (#41) by Astamur Kirillin · 9 months ago
  51. f520aa7 [FLINK-30356] Update NOTICE file to state "Apache Flink AWS connectors" by Martijn Visser · 10 months ago
  52. 1646ec0 [FLINK-30353][ci] Limit concurrency by Chesnay Schepler · 10 months ago
  53. d0817fe [FLINK-30384][Connector/AWS] Sync master KDS/KDF/Base connector changes to flink-connector-aws by Danny Cranmer · 10 months ago
  54. 5768b29 [hotfix][docs] Fix shortcode reference by Danny Cranmer · 10 months ago
  55. 83cec83 Update version to 4.1-SNAPSHOT by Danny Cranmer · 10 months ago
  56. 1787764 [hotfix][docs] Fixing SQL artifact shortcode args by Danny Cranmer · 10 months ago v4.0
  57. da1ddb0 [FLINK-29907][Connectors/Kinesis][Connectors/Firehose] Externalize Kinesis/Firehose documentation by Danny Cranmer · 10 months ago
  58. df4e3d3 [FLINK-29908] Adding e2e tests CI step by Danny Cranmer · 10 months ago
  59. 861b8d7 [FLINK-29908][Connectors/Firehose] Externalize and configure E2E tests for Kinesis connector by Danny Cranmer · 10 months ago
  60. d9a3b05 [FLINK-29908][Connectors/Firehose] Externalize and configure E2E tests for Kinesis connector v2 by Danny Cranmer · 10 months ago
  61. 79f627a [FLINK-29908][Connectors/Firehose] Externalize and configure E2E tests for Firehose connectors by Danny Cranmer · 10 months ago
  62. aa10d88 [FLINK-29907][Connectors/AWS] Fix NOTICE file for Firehose SQL connector by Danny Cranmer · 10 months ago
  63. d5d6a63 [FLINK-29907][Connectors/Kinesis] Sync changes from release-1.16 branch by Danny Cranmer · 10 months ago
  64. 8844ea1 [FLINK-29907][Connectors/AWS] Update NOTICE files by Danny Cranmer · 10 months ago
  65. a23e101 [FLINK-29907][Connectors/Kinesis] Externalize Amazon Kinesis connectors from Flink repo by Danny Cranmer · 10 months ago
  66. d5375d8 [FLINK-29907][Connectors/Kinesis] Externalize Amazon Kinesis v2 connectors from Flink repo by Danny Cranmer · 10 months ago
  67. 5993e34 [FLINK-29907][Connectors/Firehose] Externalize Amazon Firehose connectors from Flink repo by Danny Cranmer · 10 months ago
  68. 89d4a55 [FLINK-29907][Connectors/AWS] Externalize AWS Base from Flink repo by Danny Cranmer · 10 months ago
  69. 569049e [FLINK-29907][Connectors/DynamoDB] Improve maven module names by Danny Cranmer · 10 months ago
  70. 1686962 [hotfix] Setup auto-linking by Chesnay Schepler · 10 months ago
  71. dd6b215 [FLINK-30230][Connectors/AWS] Drop CI build for Flink 1.15 by Danny Cranmer · 10 months ago
  72. 412d00a [release][Connectors/AWS] Updating version to 4.0-SNAPSHOT by Danny Cranmer · 10 months ago
  73. 5ee704a [release][Connectors/AWS] Updating version to 4.0.0-SNAPSHOT by Danny Cranmer · 10 months ago
  74. 4b0f7b0 [release][Connectors/AWS] Updating version to 3.0.0-SNAPSHOT by Danny Cranmer · 10 months ago
  75. 763a03d [FLINK-25859][Connectors/DynamoDB][docs] DynamoDB sink documentation by Danny Cranmer · 10 months ago
  76. 9e09d57 [FLINK-29895][Connectors/DynamoDB] Further increase unit test coverage for DynamoDbSink by Hong Liang Teoh · 10 months ago
  77. 617d02c [hotfix][Connectors/AWS] Fix Flink configuration in CI build by Danny Cranmer · 10 months ago
  78. 89aba34 [FLINK-29895][Connectors/DynamoDB] Increase unit test coverage for DynamoDb sink by Hong Liang Teoh · 11 months ago
  79. 1b93f02 [FLINK-29895][Connectors/DynamoDB] Migrate configuration validation tests to unit tests by Hong Liang Teoh · 11 months ago
  80. a1d9391 [FLINK-29900][Connectors/DynamoDB] Make configurations for DynamoDB Table API sink follow the standard AWS and HTTP client convention by Hong Liang Teoh · 10 months ago
  81. 170947e [FLINK-29906] Added xml checkstyle plugin to check tab indent in xml files by darenwkt · 10 months ago
  82. b2606b6 [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink by Hong Liang Teoh · 11 months ago
  83. 7dfebdd [FLINK-30096][Connectors/DynamoDB] Rename destination table name to table name by Hong Liang Teoh · 11 months ago
  84. 53ea410 [FLINK-30098][Connectors/DynamoDB] Migrate DynamoDb unit tests to JUnit5 (#23) by Hong Liang Teoh · 10 months ago
  85. dc09993 [FLINK-29444][Connectors/AWS] Syncing parent pom to elasticsearch in prep for release by Danny Cranmer · 11 months ago
  86. 77916b6 [FLINK-30008][Connectors/AWS] Upgrade to Flink 1.16.0 and add CI build profile by Danny Cranmer · 11 months ago
  87. 4427bcd [FLINK-29688][Connectors/DynamoDB] Add test to detect changes in DynamoDB model (#22) by Danny Cranmer · 11 months ago
  88. 185187b [hotfix] Fixing code to pass spotless by Danny Cranmer · 11 months ago
  89. 7ec7a0b [FLINK-29960] Update Readme for name change. by Andrew Cooper · 11 months ago
  90. bd1edd6 [FLINK-29954][Connectors/DynamoDB] Improve DynamoDB Connector Sample Code by Danny Cranmer · 11 months ago
  91. 611653b [FLINK-29937][Connectors/DynamoDB] Rename DynamoDBEnhancedElementConverter to DynamoDbBeanElementConverter. Add missing @PublicEvolving and tweak comments by Danny Cranmer · 11 months ago
  92. a28dc94 [FLINK-29937][Connectors/DynamoDB] Enhanced DynamoDB Element Converter by Danny Cranmer · 11 months ago
  93. 537be3f [FLINK-29246][Connectors/DynamoDB] Update NOTICE file for SQL connector by Danny Cranmer · 11 months ago
  94. 3798aab [FLINK-29909][Connectors/DynamoDB] Update package names to follow convention of other AWS connectors by Hong Liang Teoh · 11 months ago
  95. 4942e69 [FLINK-29905][Connectors/AWS] Migrate DynamoDB parent pom to generic AWS connectors pom by Danny Cranmer · 11 months ago
  96. 11bcbf9 [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector by nir.tsruya · 1 year, 2 months ago
  97. 399b3af [FLINK-29896][ci] hotfix for build failure due to yaml literal typo (#11) by darenwkt · 11 months ago
  98. 6a2b489 [FLINK-29310] Added license check by darenwkt · 12 months ago
  99. 4357607 [FLINK-29441] Setup (fix) convergence configuration by Danny Cranmer · 1 year ago
  100. 9060c82 [FLINK-29439] Add project README by Danny Cranmer · 1 year ago