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
