Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4803#discussion_r145122089
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
---
@@ -402,25 +401,4 @@ public void run() {
}
}
}
-
- private static final class MetricRegistryThreadFactory implements
ThreadFactory {
- private final ThreadGroup group;
- private final AtomicInteger threadNumber = new AtomicInteger(1);
-
- MetricRegistryThreadFactory() {
- SecurityManager s = System.getSecurityManager();
- group = (s != null) ? s.getThreadGroup() :
Thread.currentThread().getThreadGroup();
- }
-
- public Thread newThread(Runnable r) {
- Thread t = new Thread(group, r, "Flink-MetricRegistry-"
+ threadNumber.getAndIncrement(), 0);
--- End diff --
The thread name will be different after this change. New thread naming
scheme is `<poolName>-thread-<threadNumber>`.
---
