[GitHub] flink pull request #4840: [FLINK-7368][metrics] Make MetricStore ThreadSafe ...

[pnowojski]

Github user pnowojski commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4840#discussion_r146831312
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/util/MutableIOMetrics.java
 ---
    @@ -79,7 +79,7 @@ public void addIOMetrics(AccessExecution attempt, 
@Nullable MetricFetcher fetche
                                fetcher.update();
                                MetricStore metricStore = 
fetcher.getMetricStore();
                                synchronized (metricStore) {
    --- End diff --
    
    Don't know why I have missed it :(


---