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 36d3416 [FLINK-25294][python] Fix cloudpickle import
add 4eea7bc [FLINK-24657][runtime] Added metric of the total real size of
input/output buffers queue
add 7b11679 [FLINK-24657][docs] Added outputQueueSize and inputQueueSize
into metrics page
add 60aa2ac [refactor][runtime] Added postfix `unsafe` for methods
ResultSubpartition#getTotalNumberOfBuffers and
ResultSubpartition#getTotalNumberOfBytes
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/ops/metrics.md | 16 ++++-
docs/content/docs/ops/metrics.md | 16 ++++-
...uffersGauge.java => InputBuffersSizeGauge.java} | 14 ++--
.../network/metrics/NettyShuffleMetricFactory.java | 4 ++
...ffersGauge.java => OutputBuffersSizeGauge.java} | 14 ++--
.../partition/BoundedBlockingSubpartition.java | 4 +-
.../partition/BufferWritingResultPartition.java | 18 +++++
.../network/partition/PipelinedSubpartition.java | 8 +--
.../io/network/partition/ResultPartition.java | 3 +
.../io/network/partition/ResultSubpartition.java | 4 +-
.../partition/SortMergeResultPartition.java | 5 ++
.../partition/SortMergeSubpartitionReader.java | 4 ++
.../network/partition/consumer/InputChannel.java | 4 ++
.../partition/consumer/RemoteInputChannel.java | 12 ++++
.../partition/consumer/SingleInputGate.java | 22 +++++-
.../partition/PipelinedSubpartitionTest.java | 4 +-
.../PipelinedSubpartitionWithReadViewTest.java | 27 ++++----
.../io/network/partition/ResultPartitionTest.java | 78 +++++++++++++++++++++-
.../io/network/partition/SubpartitionTestBase.java | 4 +-
.../partition/consumer/RemoteInputChannelTest.java | 32 +++++++++
20 files changed, 248 insertions(+), 45 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/{InputBuffersGauge.java
=> InputBuffersSizeGauge.java} (77%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/{OutputBuffersGauge.java
=> OutputBuffersSizeGauge.java} (76%)
