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 36e5972 [FLINK-17062][python] Fix the conversion from Java row type
to Python row type
add b8f0bf4 [FLINK-16864][metrics] Add IdleTime metric for task This pr
adds an IdleTime metric which measures idle time of a task including the time
cost for mail processor to wait for new mail and the time cost in record writer
to waiting a new buffer.
No new revisions were added by this update.
Summary of changes:
docs/monitoring/metrics.md | 5 +
docs/monitoring/metrics.zh.md | 5 +
.../state/api/runtime/SavepointEnvironment.java | 3 +-
.../network/api/writer/BroadcastRecordWriter.java | 8 +-
.../api/writer/ChannelSelectorRecordWriter.java | 4 +-
.../io/network/api/writer/RecordWriter.java | 27 +++-
.../network/api/writer/ResultPartitionWriter.java | 8 ++
.../runtime/io/network/buffer/BufferProvider.java | 7 +
.../runtime/io/network/buffer/LocalBufferPool.java | 5 +
.../io/network/partition/ResultPartition.java | 6 +
.../apache/flink/runtime/metrics/MetricNames.java | 2 +
.../runtime/metrics/groups/TaskIOMetricGroup.java | 7 +
...bleNotifyingResultPartitionWriterDecorator.java | 5 +
.../AbstractCollectingResultPartitionWriter.java | 5 +
.../io/network/api/writer/RecordWriterTest.java | 160 +++++++++++++++------
.../runtime/io/network/buffer/NoOpBufferPool.java | 5 +
.../partition/MockResultPartitionWriter.java | 5 +
.../io/network/util/TestPooledBufferProvider.java | 9 ++
.../metrics/groups/TaskIOMetricGroupTest.java | 2 +
.../flink/streaming/runtime/tasks/StreamTask.java | 1 +
.../runtime/tasks/mailbox/MailboxProcessor.java | 23 ++-
.../tasks/mailbox/TaskMailboxProcessorTest.java | 54 +++++++
22 files changed, 304 insertions(+), 52 deletions(-)
