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