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 d4a5467 [FLINK-20285][runtime] LazyFromSourcesSchedulingStrategy
checks vertex's right before scheduling it
add 1a9212c [hotfix] Fix the SingleThreadFetcherManager to get the
running fetchers correctly.
add 2e2f637 [FLINK-20194] Change SourceReaderBase.onSplitFinished() to
take a map of SplitId -> SplitState.
add 4bde1c9 [FLINK-20194] Fix Kafka offset commit to coorectly handle the
following cases: 1. The SplitFetcher has exited. 2. The offsets to be committed
is empty. 3. The offsets commit for finished splits.
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/SourceReaderBase.java | 8 +-
.../reader/fetcher/SingleThreadFetcherManager.java | 6 +-
.../source/reader/fetcher/SplitFetcherManager.java | 8 ++
.../base/source/reader/SourceReaderBaseTest.java | 4 +-
.../base/source/reader/mocks/MockSourceReader.java | 4 +-
.../connector/file/src/impl/FileSourceReader.java | 4 +-
.../kafka/source/reader/KafkaSourceReader.java | 54 ++++++--
.../reader/fetcher/KafkaSourceFetcherManager.java | 24 +++-
.../kafka/source/reader/KafkaSourceReaderTest.java | 147 +++++++++++++++------
9 files changed, 197 insertions(+), 62 deletions(-)
