diff --git a/storm-core/src/clj/org/apache/storm/util.clj b/storm-core/src/clj/org/apache/storm/util.clj index 23d39f672c0..9170ebc9d8f 100644 --- a/storm-core/src/clj/org/apache/storm/util.clj +++ b/storm-core/src/clj/org/apache/storm/util.clj @@ -553,7 +553,8 @@ (catch InterruptedException e (log-message log-prefix " interrupted."))) (exit-code-callback (.exitValue process))) - nil))) + nil) + :kill-fn (fn [error] (log-error (RuntimeException. ("launch process failed...")))))) process))) (defn exists-file?