fix: 1.4.0 fix operate log #4686 (#4695)

apache · Jun 24, 2023 · dc8db19 · dc8db19
1 parent 29925cf
commit dc8db19
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/...-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java b/...-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java
@@ -359,7 +359,9 @@ public Message executeECMOperation(HttpServletRequest req, @RequestBody JsonNode
           "Fail to process the operation parameters, cased by "
               + ExceptionUtils.getRootCauseMessage(e));
     }
-    return executeECMOperation(ecmNode, "", new ECMOperateRequest(userName, parameters));
+    String engineConnInstance = (String) parameters.get("engineConnInstance");
+    return executeECMOperation(
+        ecmNode, engineConnInstance, new ECMOperateRequest(userName, parameters));
   }
 
   @ApiOperation(value = "openEngineLog", notes = "open Engine log", response = Message.class)

diff --git a/...ive/src/main/scala/org/apache/linkis/engineplugin/hive/conf/HiveEngineConfiguration.scala b/...ive/src/main/scala/org/apache/linkis/engineplugin/hive/conf/HiveEngineConfiguration.scala
@@ -44,9 +44,6 @@ object HiveEngineConfiguration {
   val HIVE_ENGINE_CONCURRENT_LIMIT =
     CommonVars[Int]("linkis.hive.engineconn.concurrent.limit", 10).getValue
 
-  val HIVE_ENGINE_CONCURRENT_SUPPORT =
-    CommonVars[Boolean]("linkis.hive.engineconn.concurrent.support", false).getValue
-
   val HIVE_RANGER_ENABLE = CommonVars[Boolean]("linkis.hive.ranger.enabled", false).getValue
 
 }
diff --git a/...e/src/main/scala/org/apache/linkis/engineplugin/hive/creation/HiveEngineConnFactory.scala b/...e/src/main/scala/org/apache/linkis/engineplugin/hive/creation/HiveEngineConnFactory.scala
@@ -18,6 +18,7 @@
 package org.apache.linkis.engineplugin.hive.creation
 
 import org.apache.linkis.common.utils.{Logging, Utils}
+import org.apache.linkis.engineconn.acessible.executor.conf.AccessibleExecutorConfiguration
 import org.apache.linkis.engineconn.common.creation.EngineCreationContext
 import org.apache.linkis.engineconn.common.engineconn.EngineConn
 import org.apache.linkis.engineconn.computation.executor.creation.ComputationSingleExecutorEngineConnFactory
@@ -96,7 +97,7 @@ class HiveEngineConnFactory extends ComputationSingleExecutorEngineConnFactory w
       engineCreationContext: EngineCreationContext
   ): AbstractHiveSession = {
     // if hive engine support concurrent, return HiveConcurrentSession
-    if (HiveEngineConfiguration.HIVE_ENGINE_CONCURRENT_SUPPORT) {
+    if (AccessibleExecutorConfiguration.ENGINECONN_SUPPORT_PARALLELISM) {
       return doCreateHiveConcurrentSession(engineCreationContext.getOptions)
     }