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 c83c186 [FLINK-14160][docs] Describe --backpressure option for Operations Playground. add f5b6952 [hotfix][task] Refactor the process of checking input index for StreamOneInputProcessor#processInput add 7aa0671 [hotfix][task] Remove unncessary SuppressWarnings from StreamOneInputProcessor add 0983d1f [hotfix][task] Remove unused argument from constructor of StreamTaskNetworkInput add c727190 [hotfix][network] Refactor the class name AsyncDataInput to PullingAsyncDataInput add 4d42eab [hotfix][task] Refactor the constrcutor of StreamTwoInputProcessor add 68386c4 [hotfix][task] Refactor the constrcutor of StreamOneInputProcessor add a80bbf1 [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on PushingAsyncDataInput#emitNext No new revisions were added by this update. Summary of changes: .../flink/runtime/io/AvailabilityListener.java | 2 +- .../flink/runtime/io/NullableAsyncDataInput.java | 6 +- ...ncDataInput.java => PullingAsyncDataInput.java} | 2 +- .../io/network/partition/consumer/InputGate.java | 4 +- .../partition/consumer/InputGateTestBase.java | 6 +- .../runtime/io/CheckpointedInputGate.java | 4 +- .../io/{StreamTaskInput.java => InputStatus.java} | 28 ++- .../runtime/io/PushingAsyncDataInput.java | 60 +++++ .../runtime/io/StreamOneInputProcessor.java | 155 +----------- .../streaming/runtime/io/StreamTaskInput.java | 10 +- .../runtime/io/StreamTaskNetworkInput.java | 54 +++-- .../runtime/io/StreamTwoInputProcessor.java | 260 ++++++++++----------- .../runtime/streamstatus/StatusWatermarkValve.java | 38 ++- .../runtime/tasks/OneInputStreamTask.java | 139 +++++++++-- .../runtime/tasks/TwoInputStreamTask.java | 28 ++- .../runtime/io/StreamTaskNetworkInputTest.java | 64 ++++- .../streamstatus/StatusWatermarkValveTest.java | 47 ++-- 17 files changed, 504 insertions(+), 403 deletions(-) rename flink-runtime/src/main/java/org/apache/flink/runtime/io/{AsyncDataInput.java => PullingAsyncDataInput.java} (96%) copy flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/{StreamTaskInput.java => InputStatus.java} (58%) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/PushingAsyncDataInput.java