diff --git a/flinkspector-core/src/main/java/io/flinkspector/core/runtime/Runner.java b/flinkspector-core/src/main/java/io/flinkspector/core/runtime/Runner.java
index 7fd8917..5f3b3c0 100644
--- a/flinkspector-core/src/main/java/io/flinkspector/core/runtime/Runner.java
+++ b/flinkspector-core/src/main/java/io/flinkspector/core/runtime/Runner.java
@@ -136,6 +136,8 @@ private void shutdownLocalCluster() throws InterruptedException {
             TestBaseUtils.stopCluster(cluster, new FiniteDuration(1000, TimeUnit.SECONDS));
         } catch (InterruptedException e) {
             throw e;
+        } catch (IllegalStateException e) {
+            //this can happen in some cases if Flink has some timers register wih akka.
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -176,8 +178,6 @@ private synchronized void cleanUp() {
         }
         try {
             shutdownLocalCluster();
-        } catch (IllegalStateException e) {
-            //this can happen in some cases if Flink has some timers register wih akka.
         } catch (InterruptedException e) {
             throw new RuntimeException("Local cluster won't shutdown!");
         }