This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from da82cb1 [FLINK-24155][documentation] Sync Chinese version of
documentation to configure CheckpointFailureManager (#17173) (#17252)
add 52a26c8 [hotfix][connector/common] Expose splitFinishedHook in
SplitFetcher for fine-grained testing
add b26f7e7 [FLINK-23773][connector/kafka] Mark empty splits as finished
to cleanup states in SplitFetcher
No new revisions were added by this update.
Summary of changes:
.../SingleThreadMultiplexSourceReaderBase.java | 3 +-
.../reader/fetcher/SingleThreadFetcherManager.java | 21 +++++++
.../base/source/reader/fetcher/SplitFetcher.java | 6 +-
.../source/reader/fetcher/SplitFetcherManager.java | 26 ++++++++-
.../source/reader/fetcher/SplitFetcherTest.java | 6 +-
.../flink/connector/kafka/source/KafkaSource.java | 14 ++++-
.../source/reader/KafkaPartitionSplitReader.java | 31 +++++++++--
.../kafka/source/reader/KafkaSourceReader.java | 10 +---
.../reader/fetcher/KafkaSourceFetcherManager.java | 8 ++-
.../kafka/source/KafkaSourceTestUtils.java | 47 ++++++++++++++++
.../reader/KafkaPartitionSplitReaderTest.java | 33 +++++++++++
.../kafka/source/reader/KafkaSourceReaderTest.java | 64 +++++++++++++++++++---
12 files changed, 237 insertions(+), 32 deletions(-)
create mode 100644
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceTestUtils.java
