This is an automated email from the ASF dual-hosted git repository.

tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new b1a409e  [FLINK-24678][runtime/metrics] Correct the metric name of map 
state contains latency
b1a409e is described below

commit b1a409ef1c53a24d717c789eea8c09ddbc94f7f1
Author: Jinzhong Li <[email protected]>
AuthorDate: Thu Oct 28 15:41:54 2021 +0800

    [FLINK-24678][runtime/metrics] Correct the metric name of map state 
contains latency
---
 .../org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java
index 6c1eb96..9368f45 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingMapState.java
@@ -217,7 +217,7 @@ class LatencyTrackingMapState<K, N, UK, UV>
         private static final String MAP_STATE_PUT_LATENCY = 
"mapStatePutLatency";
         private static final String MAP_STATE_PUT_ALL_LATENCY = 
"mapStatePutAllLatency";
         private static final String MAP_STATE_REMOVE_LATENCY = 
"mapStateRemoveLatency";
-        private static final String MAP_STATE_CONTAINS_LATENCY = 
"mapStateContainsAllLatency";
+        private static final String MAP_STATE_CONTAINS_LATENCY = 
"mapStateContainsLatency";
         private static final String MAP_STATE_ENTRIES_INIT_LATENCY = 
"mapStateEntriesInitLatency";
         private static final String MAP_STATE_KEYS_INIT_LATENCY = 
"mapStateKeysInitLatency";
         private static final String MAP_STATE_VALUES_INIT_LATENCY = 
"mapStateValuesInitLatency";

Reply via email to