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 fd448ef [FLINK-20711][docs] Fix failure-handler parameter enumeration
value typo in ES connector doc
new a8ec54c [hotfix][metrics] Rename constant IS_BACKPRESSURE to
IS_BACK_PRESSURE
new 8d4be69 [hotfix][task] Optimize and simplify Task#isBackPressured
new 9c68f02 [FLINK-20717][metrics] Provide new
backPressuredTimeMsPerSecond metric
new a137963 [FLINK-20718][metrics] Add busyTimeMsPerSecond metric
new 6da735c [FLINK-14814][webui] Display back pressured and busy times
new b71f858 [FLINK-14814][webui] Color nodes based on back pressure
new 7aafc4c [FLINK-19174][metrics] Fix idle and backpressured time
accuracy on long sleeps
The 7 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:
docs/ops/metrics.md | 12 ++-
docs/ops/metrics.zh.md | 12 ++-
.../flink/metrics/slf4j/Slf4jReporterTest.java | 4 +-
.../web-dashboard/src/app/interfaces/job-detail.ts | 2 +
.../pages/job/overview/job-overview.component.ts | 30 ++++--
.../src/app/services/metrics.service.ts | 38 ++++++++
.../src/app/share/common/dagre/node.component.html | 34 ++++---
.../src/app/share/common/dagre/node.component.less | 9 +-
.../src/app/share/common/dagre/node.component.ts | 82 +++++++++++++++++
.../partition/BufferWritingResultPartition.java | 16 ++--
.../apache/flink/runtime/metrics/MetricNames.java | 4 +-
.../apache/flink/runtime/metrics/TimerGauge.java | 82 +++++++++++++++++
.../runtime/metrics/groups/TaskIOMetricGroup.java | 29 +++++-
.../flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
.../org/apache/flink/runtime/taskmanager/Task.java | 10 +-
.../io/network/partition/ResultPartitionTest.java | 10 +-
.../flink/runtime/metrics/TimerGaugeTest.java | 86 +++++++++++++++++
.../metrics/groups/TaskIOMetricGroupTest.java | 15 ++-
.../streaming/runtime/tasks/SourceStreamTask.java | 2 +
.../flink/streaming/runtime/tasks/StreamTask.java | 49 ++++++----
.../runtime/tasks/mailbox/MailboxProcessor.java | 17 ----
.../runtime/tasks/SourceStreamTaskTest.java | 4 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 102 +++++++++++++++++++++
.../tasks/mailbox/TaskMailboxProcessorTest.java | 67 --------------
24 files changed, 565 insertions(+), 153 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/TimerGauge.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/TimerGaugeTest.java
