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 ac0799a [hotfix][test] Prefer propogate exceptions
add dc74248 [FLINK-13051][runtime] Replace the non-selectable stream task
with the input-selectable one
add 8ca6a09 [hotfix][runtime] Remove the unused
StreamOperatorFactory#isOperatorSelectiveReading method
add 6779bd6 [hotfix][runtime] Clean up unnecessary type argument
declarations in TwoInputStreamTaskTest and TwoInputStreamTaskTestHarness
add d23e237 [hotfix][runtime] Clean up unused member variables in
StreamTwoInputSelectableProcessor
add 7e21ec8 [FLINK-13051][runtime] Drop the non-selectable StreamTask and
InputProcessor
add ce55783 [FLINK-13051][runtime] Rename TwoInputSelectableStreamTask
and StreamTwoInputSelectableProcessor
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/api/graph/StreamGraph.java | 5 +-
.../api/operators/SimpleOperatorFactory.java | 5 -
.../api/operators/StreamOperatorFactory.java | 5 -
.../runtime/io/StreamTwoInputProcessor.java | 577 +++++++++------------
.../io/StreamTwoInputSelectableProcessor.java | 425 ---------------
.../runtime/io/TwoInputSelectionHandler.java | 15 +-
.../tasks/TwoInputSelectableStreamTask.java | 72 ---
.../runtime/tasks/TwoInputStreamTask.java | 15 +-
.../tasks/StreamTaskSelectiveReadingTest.java | 2 +-
.../runtime/tasks/TwoInputStreamTaskTest.java | 181 ++-----
.../tasks/TwoInputStreamTaskTestHarness.java | 25 +-
.../runtime/operators/CodeGenOperatorFactory.java | 6 -
.../operators/join/Int2HashJoinOperatorTest.java | 7 +-
.../runtime/StreamTaskSelectiveReadingITCase.java | 2 +-
14 files changed, 349 insertions(+), 993 deletions(-)
delete mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputSelectableProcessor.java
delete mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputSelectableStreamTask.java
