增加kill all方法调用

WeDataSphere · Jan 15, 2025 · c53ab7d · c53ab7d
1 parent d25f96c
commit c53ab7d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...n/scala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCEngineConnExecutor.scala b/...n/scala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCEngineConnExecutor.scala
@@ -348,10 +348,12 @@ class JDBCEngineConnExecutor(override val outputPrintLimit: Int, val id: Int)
 
   override def close(): Unit = {
     logger.info("Start closing the jdbc engine.")
+    Utils.tryQuietly(killAll())
     connectionManager.close()
     if (JDBCConfiguration.JDBC_KERBEROS_ENABLE.getValue) {
       connectionManager.shutdownRefreshKerberosLoginService()
     }
+
     logger.info("The jdbc engine has closed successfully.")
   }