You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/11/16 14:05:19 UTC
flink git commit: [hotfix] [metrics] MetricRegistry threadNumber
starts at 1
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 <ch...@apache.org>
Authored: Wed Nov 16 15:03:11 2016 +0100
Committer: zentol <ch...@apache.org>
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);
}