Repository: flink Updated Branches: refs/heads/master 53aae50e5 -> 611412c6b
[hotfix] [metrics] MetricRegistry threadNumber starts at 1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/611412c6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/611412c6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/611412c6 Branch: refs/heads/master Commit: 611412c6b4072077adba21250e2244094be93764 Parents: 53aae50 Author: zentol <[email protected]> Authored: Wed Nov 16 15:03:11 2016 +0100 Committer: zentol <[email protected]> Committed: Wed Nov 16 15:04:51 2016 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/flink/runtime/metrics/MetricRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/611412c6/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java ---------------------------------------------------------------------- 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 index c333c26..c17fdb4 100644 --- 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 @@ public class MetricRegistry { } 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); }
