From b08c19466496154ebb794ea011b437be3f0f2a0a Mon Sep 17 00:00:00 2001
From: Alexander Kolb <alexander.kolb@ottogroup.com>
Date: Tue, 2 Jan 2018 09:17:42 +0100
Subject: [PATCH] release 0.8.2 scala 2.11

---
 .../src/main/java/io/flinkspector/core/runtime/Runner.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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!");
         }