This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.3.2
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.3.2 by this push:
new 52d8a765b [feat:4128] add ecm link log (#4129)
52d8a765b is described below
commit 52d8a765bb15b30d1b335ea9af18650eedb9e123
Author: aiceflower <[email protected]>
AuthorDate: Thu Feb 16 15:08:10 2023 +0800
[feat:4128] add ecm link log (#4129)
[feat:4128] add ecm link log (#4129)
---
.../service/impl/AbstractEngineConnLaunchService.scala | 18 ++++++++++++------
1 file changed, 12 insertions(+), 6 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 d2bc5ec41..6ac10d1e1 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
@@ -97,20 +97,24 @@ abstract class AbstractEngineConnLaunchService extends
EngineConnLaunchService w
afterLaunch(request, conn, duration)
val future = Future {
- logger.info("wait engineConn {} start", conn.getServiceInstance)
+ logger.info(
+ "TaskId: {} with request {} wait engineConn {} start",
+ Array(taskId, request, conn.getServiceInstance): _*
+ )
waitEngineConnStart(request, conn, duration)
}
future onComplete {
case Failure(t) =>
logger.error(
- "TaskId: {} init {} failed. {}",
+ "TaskId: {} init {} failed. {} with request {}",
Array(
taskId,
conn.getServiceInstance,
conn.getEngineConnLaunchRunner.getEngineConnLaunch
.getEngineConnManagerEnv()
- .engineConnWorkDir
+ .engineConnWorkDir,
+ request
): _*
)
LinkisECMApplication.getContext.getECMSyncListenerBus.postToAll(
@@ -118,25 +122,27 @@ abstract class AbstractEngineConnLaunchService extends
EngineConnLaunchService w
)
case Success(_) =>
logger.info(
- "TaskId: {} init {} succeed. {}",
+ "TaskId: {} init {} succeed. {} with request {}",
Array(
taskId,
conn.getServiceInstance,
conn.getEngineConnLaunchRunner.getEngineConnLaunch
.getEngineConnManagerEnv()
- .engineConnWorkDir
+ .engineConnWorkDir,
+ request
): _*
)
}
} { t =>
logger.error(
- "TaskId: {} init {} failed, {}, now stop and delete it. message: {}",
+ "TaskId: {} init {} failed, {}, with request {} now stop and delete
it. message: {}",
Array(
taskId,
conn.getServiceInstance,
conn.getEngineConnLaunchRunner.getEngineConnLaunch
.getEngineConnManagerEnv()
.engineConnWorkDir,
+ request,
t.getMessage,
t
): _*
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
