Update KSML Runner to properly shut down executor service. Caused KSM…

…L Java process to keep running (#88)
Axual · Jan 10, 2024 · d382bcd · d382bcd
1 parent 4bd3849
commit d382bcd
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/ksml-runner/src/main/java/io/axual/ksml/runner/KSMLRunner.java b/ksml-runner/src/main/java/io/axual/ksml/runner/KSMLRunner.java
@@ -127,6 +127,8 @@ private static void run(Backend backend) {
             backendFuture.get();
             // Future, check exit state of backend
         } catch (ExecutionException | InterruptedException e) {
+            throw FatalError.reportAndExit(new KSMLExecutionException("Exception caught", e));
+        }finally {
             executorService.shutdown();
             try {
                 if (!executorService.awaitTermination(800, TimeUnit.MILLISECONDS)) {
@@ -136,7 +138,7 @@ private static void run(Backend backend) {
                 executorService.shutdownNow();
                 throw FatalError.reportAndExit(new KSMLExecutionException("Exception caught", e2));
             }
-            throw FatalError.reportAndExit(new KSMLExecutionException("Exception caught", e));
+
         }
     }
 }