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
index 5c1282e3..7acb1576 100644
--- 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));
+
         }
     }
 }