[KYUUBI #6843] FIX 'query-timeout-thread' thread leak

apache · Dec 9, 2024 · 9e1a015 · 9e1a015
1 parent 78a9fde
commit 9e1a015
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/PlanOnlyStatement.scala b/...ql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/PlanOnlyStatement.scala
@@ -67,12 +67,11 @@ class PlanOnlyStatement(
             statement)
           resultSet =
             ResultSetUtil.fromResultFetcher(resultFetcher, resultMaxRows, resultFetchTimeout);
-          shutdownTimeoutMonitor
         case _ =>
           explainOperation(statement)
-          shutdownTimeoutMonitor
       }
     } catch {
+      shutdownTimeoutMonitor
       onError()
     }
   }