Merge branch 'dev-1.10.0-webank' of https://github.com/WeDataSphere/l…

…inkis into dev-1.10.0-webank
WeDataSphere · Jan 13, 2025 · d25f96c · d25f96c
2 parents db8b7de + a227f2a
commit d25f96c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/.../org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala b/.../org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala
@@ -376,7 +376,7 @@ class TaskExecutionServiceImpl
     val sleepInterval = ComputationExecutorConf.ENGINE_PROGRESS_FETCH_INTERVAL.getValue
     scheduler.submit(new Runnable {
       override def run(): Unit = {
-        logger.info(s"start daemon thread ${task.getTaskId}, ${task.getStatus}")
+        logger.info(s"start progress daemon thread for task ${task.getTaskId}, status ${task.getStatus}")
         Utils.tryQuietly(Thread.sleep(TimeUnit.MILLISECONDS.convert(1, TimeUnit.SECONDS)))
         while (!ExecutionNodeStatus.isCompleted(task.getStatus)) {
           Utils.tryAndWarn {
@@ -419,7 +419,7 @@ class TaskExecutionServiceImpl
             Thread.sleep(TimeUnit.MILLISECONDS.convert(sleepInterval, TimeUnit.SECONDS))
           )
         }
-        logger.info(s"daemon thread exit ${task.getTaskId}, ${task.getStatus}")
+        logger.info(s"End progress daemon thread exit task ${task.getTaskId}, status ${task.getStatus}")
       }
     })
   }

diff --git a/...plication-manager/src/main/scala/org/apache/linkis/manager/rm/restful/RMMonitorRest.scala b/...plication-manager/src/main/scala/org/apache/linkis/manager/rm/restful/RMMonitorRest.scala
@@ -137,7 +137,6 @@ class RMMonitorRest extends Logging {
 
   def appendMessageData(message: Message, key: String, value: AnyRef): Message = {
     val result = mapper.writeValueAsString(value)
-    logger.info(s"appendMessageData result: $result")
     message.data(key, mapper.readTree(result))
   }