This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 741b8e2 [FLINK-20404][zookeeper] Disable JMX log4j integration
new 4b0b4df [hotfix][connector/common] Allow adding external tasks to the
SplitFetcher. It helps avoid synchronizations between fetcher thread and main
thread.
new ceda808 [FLINK-19717][connectors/common] Fix spurious
InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader
exception (#13776)
new fe2b269 [FLINK-19448][connector/common] Fix handling of finished
splits and closing split fetchers in SourceReaderBase
new 847dc9b [FLINK-19253][connector/common] Synchronize setting the
isIdle flag in SourceReaderBase.
new 69e9d3c [FLINK-19253][connector/common][test] Add test case to test
when all split fetchers are closed with leftover element in queue
new 1958d8f [minor] Fix the test name of
SourceReaderBaseTest.testPollNextReturnMoreAvailableWhenAllSplitFetcherCloseWithLeftoverElementInQueue.
new 054e27c [FLINK-20081][connector/common][source] The SourceCoordinator
should fail the job instead of killing JM when it catches an unhandled
exception.
new 47c2d97 [FLINK-20081][connector/common][source] Fix the executor
notifier to let the handler run in main thread when handling exception from the
callable.
The 8 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:
.../SingleThreadMultiplexSourceReaderBase.java | 19 +++
.../base/source/reader/SourceReaderBase.java | 6 +-
.../base/source/reader/fetcher/FetchTask.java | 6 +-
.../base/source/reader/fetcher/SplitFetcher.java | 51 +++++--
.../source/reader/fetcher/SplitFetcherManager.java | 13 +-
.../base/source/reader/SourceReaderBaseTest.java | 157 ++++++++++++++++++++-
.../source/reader/fetcher/SplitFetcherTest.java | 4 +-
.../base/source/reader/mocks/MockSourceReader.java | 8 ++
.../base/source/reader/mocks/MockSplitReader.java | 57 +++++++-
.../connector/source/SplitEnumeratorContext.java | 4 +
.../source/coordinator/ExecutorNotifier.java | 5 +-
.../coordinator/SourceCoordinatorProvider.java | 11 +-
.../source/coordinator/ExecutorNotifierTest.java | 25 +++-
.../coordinator/SourceCoordinatorContextTest.java | 3 +-
.../coordinator/SourceCoordinatorProviderTest.java | 21 +++
.../coordinator/SourceCoordinatorTestBase.java | 3 +-
16 files changed, 359 insertions(+), 34 deletions(-)
