From a217eb9a8a80b38c970021faad76a4b9fcade609 Mon Sep 17 00:00:00 2001
From: Steven Zhang <35498506+stevenpyzhang@users.noreply.github.com>
Date: Fri, 27 Mar 2020 15:31:12 -0400
Subject: [PATCH] fix: logic when closing ksqlEngine fixed (#4917)

---
 ksql-engine/src/main/java/io/confluent/ksql/KsqlEngine.java | 3 ++-
 1 file changed, 2 insertions(+), 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
index 2844c7cea416..e3cf3b4706f0 100644
--- 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();