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/04/27 01:06:48 UTC

[flink] branch master updated (a9f8a0b -> 90a38e8)

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 a9f8a0b  [FLINK-17339][misc] Update tests due to default planner changing.
     add 237a63f  [FLINk-17268][connector/common] Fix the bug of missing records during SplitFetcher wakeup. Added unit test for SplitFetcher.
     add b7b2c43  [hotfix] Remove the unused Boundedness parameter.
     add 90a38e8  [FLINK-17268][connector/common] Fix the shutdown sequence in SplitFetcher to avoid blocking on shutdown. Fix flaky SourceReaderTestBase#testAvailableOnEmptyQueue().

No new revisions were added by this update.

Summary of changes:
 .../base/source/reader/fetcher/FetchTask.java      |  59 +++++++----
 .../base/source/reader/fetcher/SplitFetcher.java   |  72 +++++++++----
 .../source/reader/fetcher/SplitFetcherManager.java |  28 ++++-
 .../base/source/reader/SourceReaderBaseTest.java   |  26 +++--
 .../base/source/reader/SourceReaderTestBase.java   |  97 ++++++++++--------
 .../source/reader/fetcher/SplitFetcherTest.java    | 114 +++++++++++++++++++++
 .../base/source/reader/mocks/MockSplitReader.java  |  42 ++++----
 .../src/test/resources/log4j2-test.properties      |  18 ++--
 .../connector/source/mocks/MockSourceSplit.java    |   6 ++
 9 files changed, 342 insertions(+), 120 deletions(-)
 create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherTest.java
 copy flink-end-to-end-tests/test-scripts/test_streaming_gcp_pubsub.sh => flink-connectors/flink-connector-base/src/test/resources/log4j2-test.properties (62%)
 mode change 100755 => 100644