This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d3f6f8e [hotfix][task] Adjust the code format of OneInputStreamTask
add 482462f [FLINK-13442][network] Remove unnecessary
notifySubpartitionConsumed method from view reader
No new revisions were added by this update.
Summary of changes:
.../apache/flink/runtime/io/network/NetworkSequenceViewReader.java | 2 --
.../io/network/netty/CreditBasedSequenceNumberingViewReader.java | 5 -----
.../flink/runtime/io/network/netty/PartitionRequestQueue.java | 1 -
.../runtime/io/network/netty/SequenceNumberingViewReader.java | 5 -----
.../runtime/io/network/partition/BoundedBlockingSubpartition.java | 2 ++
.../io/network/partition/BoundedBlockingSubpartitionReader.java | 5 -----
.../runtime/io/network/partition/NoOpResultSubpartitionView.java | 4 ----
.../runtime/io/network/partition/PipelinedSubpartitionView.java | 5 -----
.../flink/runtime/io/network/partition/ResultSubpartitionView.java | 2 --
.../flink/runtime/io/network/partition/consumer/InputChannel.java | 2 --
.../runtime/io/network/partition/consumer/LocalInputChannel.java | 7 -------
.../runtime/io/network/partition/consumer/RemoteInputChannel.java | 5 -----
.../runtime/io/network/partition/consumer/SingleInputGate.java | 1 -
.../runtime/io/network/partition/consumer/UnknownInputChannel.java | 4 ----
.../flink/runtime/io/network/netty/CancelPartitionRequestTest.java | 6 ------
.../flink/runtime/io/network/partition/ResultPartitionTest.java | 2 +-
.../runtime/io/network/partition/consumer/InputChannelTest.java | 4 ----
.../runtime/io/network/partition/consumer/TestInputChannel.java | 5 -----
.../flink/runtime/io/network/util/TestSubpartitionConsumer.java | 2 +-
19 files changed, 4 insertions(+), 65 deletions(-)
