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(-)