Commit for work

apache · Mar 22, 2023 · 5ee9ddf · 5ee9ddf
1 parent d9f9e3c
commit 5ee9ddf
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala
@@ -110,17 +110,17 @@ class KyuubiSyncThriftClient private (
           }
         } else {
           shutdownAsyncRequestExecutor()
-          Utils.tryLogNonFatalError {
-            Option(engineAliveThreadPool).foreach { pool =>
-              ThreadUtils.shutdown(pool, Duration(engineAliveProbeInterval, TimeUnit.MILLISECONDS))
-            }
-            warn(s"Removing Clients for ${_remoteSessionHandle}")
-            Seq(protocol).union(engineAliveProbeProtocol.toSeq).foreach { tProtocol =>
+          warn(s"Removing Clients for ${_remoteSessionHandle}")
+          Seq(protocol).union(engineAliveProbeProtocol.toSeq).foreach { tProtocol =>
+            Utils.tryLogNonFatalError {
               if (tProtocol.getTransport.isOpen) {
                 tProtocol.getTransport.close()
               }
             }
             clientClosedOnEngineBroken = true
+            Option(engineAliveThreadPool).foreach { pool =>
+              ThreadUtils.shutdown(pool, Duration(engineAliveProbeInterval, TimeUnit.MILLISECONDS))
+            }
           }
         }
       }