HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939317
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java
##########
@@ -67,6 +67,7 @@ private MetricNames() {
public static final String CHECKPOINT_ALIGNMENT_TIME =
"checkpointAlignmentTime";
public static final String CHECKPOINT_START_DELAY_TIME =
"checkpointStartDelayNanos";
+ public static final String WORKER_FAILURE_RATE = "workFailureRate";
Review comment:
Done.
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
##########
@@ -108,6 +111,8 @@
public static final String RESOURCE_MANAGER_NAME = "resourcemanager";
+ protected final Logger log = LoggerFactory.getLogger(getClass());
Review comment:
Done.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
