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:44 UTC
[incubator-linkis] 07/11: optimize 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 7af91ca6c5344dc427e0137a4298d7d28ae5570d
Author: peacewong <wp...@gmail.com>
AuthorDate: Thu Apr 28 19:58:59 2022 +0800
optimize log
---
.../computation/service/ComputationTaskExecutionReceiver.scala | 2 +-
.../org/apache/linkis/orchestrator/listener/task/TaskInfoEvent.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/service/ComputationTaskExecutionReceiver.scala b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/service/ComputationTaskExecutionReceiver.scala
index 5c74f3855..0f342ecb8 100644
--- a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/service/ComputationTaskExecutionReceiver.scala
+++ b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/service/ComputationTaskExecutionReceiver.scala
@@ -162,7 +162,7 @@ class ComputationTaskExecutionReceiver extends TaskExecutionReceiver with Loggin
val serviceInstance = RPCUtils.getServiceInstanceFromSender(sender)
codeExecTaskExecutorManager.getByEngineConnAndTaskId(serviceInstance, responseTaskError.execId).foreach { codeExecutor =>
val event = TaskErrorResponseEvent(codeExecutor.getExecTask, responseTaskError.errorMsg)
- logger.info(s"From engineConn receive responseTaskError info$responseTaskError, now post to listenerBus event: $event")
+ logger.info(s"From engineConn receive responseTaskError info${responseTaskError.execId}, now post to listenerBus event: ${event.execTask.getIDInfo()}")
codeExecutor.getExecTask.getPhysicalContext.broadcastSyncEvent(event)
codeExecutor.getEngineConnExecutor.updateLastUpdateTime()
isExist = true
diff --git a/linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/listener/task/TaskInfoEvent.scala b/linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/listener/task/TaskInfoEvent.scala
index 661750fc0..d53ceed55 100644
--- a/linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/listener/task/TaskInfoEvent.scala
+++ b/linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/listener/task/TaskInfoEvent.scala
@@ -55,7 +55,7 @@ case class TaskResultSetSizeEvent(execTask: ExecTask, resultSize: Int) extends T
case class TaskErrorResponseEvent(execTask: ExecTask, errorMsg: String) extends TaskInfoEvent with OrchestratorSyncEvent {
override def toString: String = {
- s"task ${execTask.getIDInfo()}, errorMsg ${errorMsg}"
+ s"task ${execTask.getIDInfo()}"
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org