You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2020/03/30 12:45:29 UTC

[flink] branch master updated (ff491bd -> 750ef68)

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from ff491bd  [FLINK-13483] Retry delete when checking path existence in AbstractHadoopFileSystemITTest
     add 0dad640  [FLINK-16806][operators] Fix shouldSetAvailableForAnotherInput for MultipleInputStreamOperator
     add f7c3d1b  [FLINK-16806][operators] Add support for InputSelection to MultipleInputStreamOperator
     add 750ef68  [hotfix][operators] Rename InputSelectable inputSelector field to inputSelectable

No new revisions were added by this update.

Summary of changes:
 .../runtime/io/MultipleInputSelectionHandler.java  |  10 +-
 .../runtime/io/StreamMultipleInputProcessor.java   |  26 +-
 .../runtime/io/TwoInputSelectionHandler.java       |   8 +-
 .../runtime/tasks/MultipleInputStreamTask.java     |   5 +-
 .../io/MultipleInputSelectionHandlerTest.java      |  52 +++
 .../tasks/StreamTaskMailboxTestHarness.java        |   9 +-
 ...treamTaskMultipleInputSelectiveReadingTest.java | 376 +++++++++++++++++++++
 .../TestAnyModeMultipleInputStreamOperator.java    |  86 +++++
 ...TestSequentialMultipleInputStreamOperator.java} |  48 +--
 9 files changed, 565 insertions(+), 55 deletions(-)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/MultipleInputSelectionHandlerTest.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMultipleInputSelectiveReadingTest.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/util/TestAnyModeMultipleInputStreamOperator.java
 copy flink-streaming-java/src/test/java/org/apache/flink/streaming/util/{TestSequentialReadingStreamOperator.java => TestSequentialMultipleInputStreamOperator.java} (56%)