This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a8ec54cb6318ae4e03bf5d50b472007d96c378e2 Author: Piotr Nowojski <[email protected]> AuthorDate: Tue Dec 22 16:37:48 2020 +0100 [hotfix][metrics] Rename constant IS_BACKPRESSURE to IS_BACK_PRESSURE --- .../src/main/java/org/apache/flink/runtime/metrics/MetricNames.java | 2 +- .../main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java index 6a8288c..ccb442b 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java @@ -57,7 +57,7 @@ public class MetricNames { public static final String MEMORY_COMMITTED = "Committed"; public static final String MEMORY_MAX = "Max"; - public static final String IS_BACKPRESSURED = "isBackPressured"; + public static final String IS_BACK_PRESSURED = "isBackPressured"; public static final String CHECKPOINT_ALIGNMENT_TIME = "checkpointAlignmentTime"; public static final String CHECKPOINT_START_DELAY_TIME = "checkpointStartDelayNanos"; diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java index 9bda8ff..57de5d0 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java @@ -696,7 +696,7 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway { partitionStateChecker, getRpcService().getExecutor()); - taskMetricGroup.gauge(MetricNames.IS_BACKPRESSURED, task::isBackPressured); + taskMetricGroup.gauge(MetricNames.IS_BACK_PRESSURED, task::isBackPressured); log.info( "Received task {} ({}), deploy into slot with allocation id {}.",
