diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hcatalog/templeton/tool/TempletonControllerJob.java hcatalog/webhcat/svr/src/main/java/org/apache/hcatalog/templeton/tool/TempletonControllerJob.java index 7799d64..d055525 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hcatalog/templeton/tool/TempletonControllerJob.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hcatalog/templeton/tool/TempletonControllerJob.java @@ -169,8 +169,10 @@ public void run(Context context) proc.waitFor(); keepAlive.sendReport = false; pool.shutdown(); - if (!pool.awaitTermination(WATCHER_TIMEOUT_SECS, TimeUnit.SECONDS)) + if (!pool.awaitTermination(WATCHER_TIMEOUT_SECS, TimeUnit.SECONDS)) { + System.err.println("Shutting down watcher/keep alive thread pool forcefully"); pool.shutdownNow(); + } writeExitValue(conf, proc.exitValue(), statusdir); JobState state = new JobState(context.getJobID().toString(), conf); @@ -273,6 +275,7 @@ public void run() { } } writer.flush(); + writer.close(); } catch (IOException e) { System.err.println("templeton: execute error: " + e); }