Kill process upon shutdown (apache#140)

sijie · Mar 4, 2018 · a2ed4c2 · a2ed4c2
1 parent d2f32e8
commit a2ed4c2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...src/main/java/org/apache/pulsar/functions/runtime/container/ProcessFunctionContainer.java b/...src/main/java/org/apache/pulsar/functions/runtime/container/ProcessFunctionContainer.java
@@ -157,6 +157,7 @@ class ProcessFunctionContainer implements FunctionContainer {
      */
     @Override
     public void start() throws Exception {
+        Runtime.getRuntime().addShutdownHook(new Thread(() -> process.destroy()));
         try {
             log.info("ProcessBuilder starting the process with args {}", String.join(" ", processBuilder.command()));
             process = processBuilder.start();