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";