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

ASiegeLion · Dec 16, 2024 · 9107a30 · 9107a30
1 parent 4b3417f
commit 9107a30
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 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,8 +67,7 @@ class PlanOnlyStatement(
             statement)
           resultSet =
             ResultSetUtil.fromResultFetcher(resultFetcher, resultMaxRows, resultFetchTimeout);
-        case _ =>
-          explainOperation(statement)
+        case _ => explainOperation(statement)
       }
     } catch {
       onError()

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala
@@ -172,9 +172,7 @@ class ExecuteStatement(
     try {
       val opHandle = sessionManager.submitBackgroundOperation(asyncOperation)
       setBackgroundHandle(opHandle)
-    } catch {
-      onError("submitting query in background, query rejected")
-    }
+    } catch onError("submitting query in background, query rejected")
 
     if (!shouldRunAsync) getBackgroundHandle.get()
   }