diff --git a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java
index e3302df089..6d3548274c 100644
--- a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java
+++ b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java
@@ -39,9 +39,11 @@
 public class EngineConnYarnLogOperator extends EngineConnLogOperator {
   private static final Logger logger = LoggerFactory.getLogger(EngineConnYarnLogOperator.class);
 
+  private static final String YARN_LOG_OPERATOR_NAME = "engineConnYarnLog";
+
   @Override
   public String[] getNames() {
-    return new String[] {EngineConnYarnLogOperator.OPERATOR_NAME};
+    return new String[] {EngineConnYarnLogOperator.YARN_LOG_OPERATOR_NAME};
   }
 
   @Override
diff --git a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
index f82c5e9441..20399711bd 100644
--- a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
+++ b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultOperateService.scala
@@ -42,9 +42,11 @@ class DefaultOperateService extends OperateService with Logging {
       engineOperateRequest: EngineOperateRequest
   ): EngineOperateResponse = {
     var response: EngineOperateResponse = null
-
-    val parameters =
-      engineOperateRequest.getParameters.asScala.toMap.asInstanceOf[util.Map[String, Object]]
+    val parameters = {
+      val map = new util.HashMap[String, Object]()
+      engineOperateRequest.getParameters.asScala.foreach(entry => map.put(entry._1, entry._2))
+      map
+    }
     val operator = Utils.tryCatch(OperatorFactory.apply().getOperatorRequest(parameters)) { t =>
       logger.error(s"Get operator failed, parameters is ${engineOperateRequest.getParameters}.", t)
       response = new EngineOperateResponse(