You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2022/04/29 15:51:39 UTC
[incubator-linkis] 02/11: ecm prints entrance taskID log
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit c669bcd5af8db0e5642fa0c4ad10fef6def23aa8
Author: peacewong <wp...@gmail.com>
AuthorDate: Thu Apr 28 17:33:18 2022 +0800
ecm prints entrance taskID log
---
.../server/service/impl/AbstractEngineConnLaunchService.scala | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/AbstractEngineConnLaunchService.scala b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/AbstractEngineConnLaunchService.scala
index 9dcef7ad6..4ec3b6a59 100644
--- a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/AbstractEngineConnLaunchService.scala
+++ b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/service/impl/AbstractEngineConnLaunchService.scala
@@ -18,7 +18,6 @@
package org.apache.linkis.ecm.server.service.impl
import java.util.concurrent.TimeUnit
-
import org.apache.linkis.common.ServiceInstance
import org.apache.linkis.common.utils.{Logging, Utils}
import org.apache.linkis.ecm.core.engineconn.{EngineConn, EngineConnInfo}
@@ -38,6 +37,7 @@ import org.apache.linkis.manager.common.protocol.engine.EngineConnStatusCallback
import org.apache.linkis.manager.engineplugin.common.launch.entity.EngineConnLaunchRequest
import org.apache.linkis.rpc.Sender
import org.apache.commons.lang.exception.ExceptionUtils
+import org.apache.linkis.governance.common.utils.JobUtils
import scala.concurrent.duration.Duration
import scala.concurrent.{Await, ExecutionContextExecutorService, Future}
@@ -64,7 +64,8 @@ abstract class AbstractEngineConnLaunchService extends EngineConnLaunchService w
override def launchEngineConn(request: EngineConnLaunchRequest, duration: Long): EngineNode = {
//1.创建engineConn和runner,launch 并设置基础属性
- info(s"Try to launch a new EngineConn with $request.")
+ val taskId = JobUtils.getJobIdFromStringMap(request.creationDesc.properties)
+ logger.info(s"TaskId: $taskId try to launch a new EngineConn with $request.")
val conn = createEngineConn
val runner = createEngineConnLaunchRunner
val launch = createEngineConnLaunch
@@ -102,13 +103,13 @@ abstract class AbstractEngineConnLaunchService extends EngineConnLaunchService w
future onComplete {
case Failure(t) =>
- logger.error(s"init ${conn.getServiceInstance} failed.${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}")
+ logger.error(s"TaskId: $taskId init ${conn.getServiceInstance} failed.${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}")
LinkisECMApplication.getContext.getECMSyncListenerBus.postToAll(EngineConnStatusChangeEvent(conn.getTickedId, Failed))
case Success(_) =>
- logger.info(s"init ${conn.getServiceInstance} succeed.${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}")
+ logger.info(s"TaskId: $taskId init ${conn.getServiceInstance} succeed.${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}")
}
} { t =>
- error(s"init ${conn.getServiceInstance} failed, ${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}, now stop and delete it. message: ${t.getMessage}", t)
+ error(s"TaskId: $taskId init ${conn.getServiceInstance} failed, ${conn.getEngineConnLaunchRunner.getEngineConnLaunch.getEngineConnManagerEnv().engineConnWorkDir}, now stop and delete it. message: ${t.getMessage}", t)
conn.getEngineConnLaunchRunner.stop()
Sender.getSender(MANAGER_SPRING_NAME).send(EngineConnStatusCallbackToAM(conn.getServiceInstance,
NodeStatus.ShuttingDown, " wait init failed , reason " + ExceptionUtils.getRootCauseMessage(t)))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org