提交 a8ec54cb 编写于 作者: P Piotr Nowojski 提交者: Piotr Nowojski

[hotfix][metrics] Rename constant IS_BACKPRESSURE to IS_BACK_PRESSURE

上级 fd448ef1
......@@ -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";
......
......@@ -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 {}.",
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册