DRILL-4049: Terminate StatusThread when Workmanager is closed. Avoid excessive growth in threads with long-lived test JVMs.
Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/ffe02403 Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/ffe02403 Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/ffe02403 Branch: refs/heads/master Commit: ffe024038f6db9eaab3e107de80ea305af9f7df8 Parents: dde1867 Author: Jacques Nadeau <[email protected]> Authored: Fri Nov 6 18:58:01 2015 -0800 Committer: Jacques Nadeau <[email protected]> Committed: Fri Nov 6 21:41:07 2015 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/drill/exec/work/WorkManager.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/ffe02403/exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java b/exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java index 9ee65b1..93fd13e 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java @@ -150,6 +150,7 @@ public class WorkManager implements AutoCloseable { @Override public void close() throws Exception { + statusThread.interrupt(); if (!runningFragments.isEmpty()) { logger.warn("Closing WorkManager but there are {} running fragments.", runningFragments.size());
