[hotfix] [metrics] MetricRegistry threadNumber starts at 1

jsimsa · Nov 16, 2016 · 611412c · 611412c
1 parent 53aae50
commit 611412c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
@@ -326,7 +326,7 @@ private static final class MetricRegistryThreadFactory implements ThreadFactory
 		}
 
 		public Thread newThread(Runnable r) {
-			Thread t = new Thread(group, r, "Flink-MetricRegistry-" + threadNumber.incrementAndGet(), 0);
+			Thread t = new Thread(group, r, "Flink-MetricRegistry-" + threadNumber.getAndIncrement(), 0);
 			if (t.isDaemon()) {
 				t.setDaemon(false);
 			}