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 2020/11/12 10:45:10 UTC

[flink] branch master updated (fb0ee3a -> 8d7e9e6)

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(-)