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 fd75bcd [hotfix][tests][coordination] Move idle task manager release
tests into a separate suite
new a68dc3c [hotfix][test] Guarantee order of CloseableRegistry
new 479b689 [hotfix][test] Move CloseableRegistry as field in
InputBuffersMetricsTest
new 282646e [hotfix][test] Deduplicate NettyShuffleEnvironmentTest code
new c27d0d6 [FLINK-13013][network] Request partitions during
InputGate#setup
new 8d277d4 [hotfix][network] Make InputGate#requestPartitions a private
method
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/flink/core/fs/CloseableRegistry.java | 16 ++-
.../flink/util/AbstractCloseableRegistry.java | 8 +-
.../io/network/partition/consumer/InputGate.java | 4 +-
.../consumer/RemoteChannelStateChecker.java | 9 +-
.../partition/consumer/SingleInputGate.java | 55 ++++----
.../network/partition/consumer/UnionInputGate.java | 17 ---
.../runtime/taskmanager/InputGateWithMetrics.java | 7 +-
.../org/apache/flink/runtime/taskmanager/Task.java | 4 +-
.../io/network/NettyShuffleEnvironmentBuilder.java | 4 +-
.../io/network/NettyShuffleEnvironmentTest.java | 91 +++----------
.../runtime/io/network/buffer/NoOpBufferPool.java | 95 +++++++++++++
.../network/partition/InputChannelTestUtils.java | 21 +++
.../network/partition/InputGateFairnessTest.java | 29 +++-
.../io/network/partition/PartitionTestUtils.java | 2 +
.../consumer/InputBuffersMetricsTest.java | 149 ++++++++++++---------
.../partition/consumer/LocalInputChannelTest.java | 8 +-
.../partition/consumer/SingleInputGateBuilder.java | 5 +
.../partition/consumer/SingleInputGateTest.java | 95 +++++++------
.../apache/flink/runtime/taskmanager/TaskTest.java | 26 +++-
.../CheckpointBarrierAlignerMassiveRandomTest.java | 3 -
.../flink/streaming/runtime/io/MockInputGate.java | 4 -
.../StreamNetworkBenchmarkEnvironment.java | 3 +-
.../StreamNetworkPointToPointBenchmark.java | 2 +-
.../StreamNetworkThroughputBenchmark.java | 2 +-
24 files changed, 400 insertions(+), 259 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NoOpBufferPool.java
