This is an automated email from the ASF dual-hosted git repository. alexkun pushed a commit to branch dev-1.2.0 in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 499ca191bfde097c56f68c46b9e81431d734db55 Author: peacewong <[email protected]> AuthorDate: Fri Jul 22 19:38:09 2022 +0800 optimize code --- .../orchestrator/computation/physical/CodeLogicalUnitExecTask.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/physical/CodeLogicalUnitExecTask.scala b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/physical/CodeLogicalUnitExecTask.scala index 4da60a065..6c17cec7b 100644 --- a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/physical/CodeLogicalUnitExecTask.scala +++ b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/physical/CodeLogicalUnitExecTask.scala @@ -91,7 +91,7 @@ class CodeLogicalUnitExecTask (parents: Array[ExecTask], children: Array[ExecTas codeExecutor.setEngineConnTaskId(engineConnExecId) codeExecTaskExecutorManager.addEngineConnTaskID(codeExecutor) val infoMap = new util.HashMap[String, Object] - infoMap.put(TaskConstant.ENGINE_INSTANCE, codeExecutor.getEngineConnExecutor.getServiceInstance) + infoMap.put(TaskConstant.ENGINE_INSTANCE, codeExecutor.getEngineConnExecutor.getServiceInstance.getInstance) val event = TaskRunningInfoEvent(this, 0f, Array.empty, new util.HashMap[String, ResourceWithStatus], infoMap) getPhysicalContext.pushProgress(event) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
