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 fb0ee3a [FLINK-20084][table-planner-blink] Fix NPE when generating
watermark for null rowtime after watermark push down
add e131a47 [FLINK-19253][connector/common] Synchronize setting the
isIdle flag in SourceReaderBase.
add 8d7e9e6 [FLINK-19253][connector/common][test] Add test case to test
when all split fetchers are closed with leftover element in queue
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/fetcher/SplitFetcher.java | 25 +++++--
.../base/source/reader/SourceReaderBaseTest.java | 81 ++++++++++++++++++++--
.../base/source/reader/mocks/MockSourceReader.java | 8 +++
3 files changed, 104 insertions(+), 10 deletions(-)
