You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by jq...@apache.org on 2021/09/06 07:45:13 UTC

[flink] branch master updated (5b47a81 -> fe17ca6)

This is an automated email from the ASF dual-hosted git repository.

jqin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 5b47a81  [FLINK-24090][docs] Added Troubleshooting section with ignoring in-flight data explanation into unaligned checkpoints page
     add 754b744  [hotfix][connector/common] Expose splitFinishedHook in SplitFetcher for fine-grained testing
     add fe17ca6  [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