diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesCounter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesCounter.java index a59d129fb5a1c..20b89227c43eb 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesCounter.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesCounter.java @@ -53,8 +53,8 @@ public class SystemResourcesCounter extends Thread { private volatile boolean running = true; - private long[] previousCpuTicks; - private long[][] previousProcCpuTicks; + private volatile long[] previousCpuTicks; + private volatile long[][] previousProcCpuTicks; private long[] bytesReceivedPerInterface; private long[] bytesSentPerInterface;