This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 774d92d [FLINK-20665][connector-fs][table] FileNotFoundException when
restore from latest Checkpoint in Sink Compaction
add 90a51a3 [FLINK-20630][dynamodb] DynamoDB Streams Consumer fails to
consume from Latest
add e99c613 [FLINK-20629][kinesis] Migrate from DescribeStream to
DescribeStreamSummary
No new revisions were added by this update.
Summary of changes:
docs/dev/connectors/kinesis.md | 4 +-
docs/dev/connectors/kinesis.zh.md | 229 ++++++++++++++++++++-
.../internals/DynamoDBStreamsDataFetcher.java | 55 +++--
.../publisher/fanout/StreamConsumerRegistrar.java | 6 +-
.../connectors/kinesis/proxy/KinesisProxyV2.java | 10 +-
.../kinesis/proxy/KinesisProxyV2Interface.java | 4 +-
.../internals/DynamoDBStreamsDataFetcherTest.java | 69 +++++++
.../kinesis/proxy/KinesisProxyV2Test.java | 32 +--
.../FakeKinesisFanOutBehavioursFactory.java | 12 +-
.../connectors/kinesis/testutils/TestUtils.java | 20 ++
.../testutils/TestableKinesisDataFetcher.java | 20 +-
11 files changed, 376 insertions(+), 85 deletions(-)
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcherTest.java
