fix: logic when closing ksqlEngine fixed (#4917)

confluentinc · Mar 27, 2020 · a217eb9 · a217eb9
1 parent 21e4751
commit a217eb9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ksql-engine/src/main/java/io/confluent/ksql/KsqlEngine.java b/ksql-engine/src/main/java/io/confluent/ksql/KsqlEngine.java
@@ -535,8 +535,9 @@ public void close() {
     for (final QueryMetadata queryMetadata : allLiveQueries) {
       if (queryMetadata instanceof PersistentQueryMetadata) {
         queryMetadata.stop();
+      } else {
+        queryMetadata.close();
       }
-      queryMetadata.close();
     }
     adminClient.close();
     engineMetrics.close();