This is an automated email from the ASF dual-hosted git repository.
fcsaky pushed a change to branch v6.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
from 373be6f [FLINK-37687] Introduce support for Flink 2.0 in
flink-connector-aws
new e622064 [FLINK-36296] Add support for incremental shard discovery for
DynamoDB Streams Source
new 82e70d5 [FLINK-37627] Fix restart from checkpoint/savepoint at shard
split can cause data loss
new defd6de [hotfix] Update project version to 6.0-SNAPSHOT
new ec97007 [hotfix] Update NOTICE dates to 2026
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
NOTICE | 4 +-
flink-connector-aws-base/pom.xml | 2 +-
.../connector/aws/util/AWSClientUtilTest.java | 6 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-connector-aws-sqs-e2e-tests/pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
flink-connector-aws-e2e-tests/pom.xml | 2 +-
.../flink-connector-aws-kinesis-firehose/pom.xml | 2 +-
.../flink-connector-aws-kinesis-streams/pom.xml | 2 +-
.../enumerator/KinesisStreamsSourceEnumerator.java | 26 +++--
.../enumerator/assigner/UniformShardAssigner.java | 3 +-
.../source/enumerator/tracker/SplitTracker.java | 6 ++
.../source/reader/KinesisStreamsSourceReader.java | 72 ++++++++++++-
.../kinesis/source/split/KinesisShardSplit.java | 32 +++++-
.../source/split/KinesisShardSplitSerializer.java | 115 +++++++++++---------
.../assigner/UniformShardAssignerTest.java | 4 +-
.../reader/KinesisStreamsSourceReaderTest.java | 120 +++++++++++++++++++++
.../split/KinesisShardSplitSerializerTest.java | 49 ++++++++-
.../source/split/KinesisShardSplitTest.java | 39 +++++++
.../connector/kinesis/source/util/TestUtil.java | 13 +++
.../flink-connector-dynamodb/pom.xml | 2 +-
.../sink/DynamoDbTypeInformedElementConverter.java | 5 +-
.../dynamodb/source/DynamoDbStreamsSource.java | 45 ++++----
.../DynamodbStreamsSourceConfigConstants.java | 4 +
.../DynamoDbStreamsSourceEnumerator.java | 26 ++++-
.../enumerator/event/SplitsFinishedEvent.java | 15 +--
.../event/SplitsFinishedEventContext.java | 52 +++++++++
.../source/enumerator/tracker/SplitTracker.java | 4 +
.../source/proxy/DynamoDbStreamsProxy.java | 43 ++++++++
.../dynamodb/source/proxy/StreamProxy.java | 10 ++
.../source/reader/DynamoDbStreamsSourceReader.java | 50 +++++++--
.../PollingDynamoDbStreamsShardSplitReader.java | 92 ++++++++++++++--
.../source/split/DynamoDbStreamsShardSplit.java | 40 ++++++-
.../split/DynamoDbStreamsShardSplitSerializer.java | 49 ++++++++-
.../split/DynamoDbStreamsShardSplitState.java | 10 ++
.../DynamoDbStreamsSourceEnumeratorTest.java | 36 ++++---
.../source/proxy/DynamoDbStreamsProxyTest.java | 86 ++++++++++++++-
.../reader/DynamoDbStreamsSourceReaderTest.java | 16 ++-
...PollingDynamoDbStreamsShardSplitReaderTest.java | 16 ++-
.../DynamoDbStreamsShardSplitSerializerTest.java | 14 +++
.../source/util/DynamoDbStreamsClientProvider.java | 29 +++++
.../source/util/DynamoDbStreamsProxyProvider.java | 23 ++++
.../connector/dynamodb/source/util/TestUtil.java | 35 ++++++
flink-connector-aws/flink-connector-sqs/pom.xml | 2 +-
.../pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink-sql-connector-dynamodb/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-connector-aws/pom.xml | 4 +-
.../flink-avro-glue-schema-registry/pom.xml | 2 +-
.../flink-json-glue-schema-registry/pom.xml | 2 +-
flink-formats-aws/pom.xml | 2 +-
flink-python/pom.xml | 4 +-
pom.xml | 4 +-
58 files changed, 1066 insertions(+), 175 deletions(-)
create mode 100644
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/event/SplitsFinishedEventContext.java
