diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java index 77ee6af..d5e5fb6 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java @@ -137,6 +137,18 @@ private ExecBean auxRun(String program, List args, Map e String enc = appConf.get(AppConfig.EXEC_ENCODING_NAME); res.stdout = outStream.toString(enc); res.stderr = errStream.toString(enc); + try { + watchdog.checkException(); + } + catch (Exception ex) { + LOG.error("Command: " + cmd + " failed:", ex); + } + if(watchdog.killedProcess()) { + String msg = " was terminated due to timeout(" + timeout + "ms). See " + AppConfig + .EXEC_TIMEOUT_NAME + " property"; + LOG.warn("Command: " + cmd + msg); + res.stderr += " Command " + msg; + } return res; }