From 59b85cff12166c91de1ee68775bf4308416f03e7 Mon Sep 17 00:00:00 2001 From: peacewong Date: Mon, 4 Sep 2023 19:20:40 +0800 Subject: [PATCH] Fix progress no push bug --- .../computation/executor/service/TaskExecutionServiceImpl.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala index a97316b35f..a60bdce7e7 100644 --- a/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala +++ b/linkis-computation-governance/linkis-engineconn/linkis-computation-engineconn/src/main/scala/org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala @@ -427,7 +427,7 @@ class TaskExecutionServiceImpl override def run(): Unit = { Utils.tryQuietly(Thread.sleep(TimeUnit.MILLISECONDS.convert(1, TimeUnit.SECONDS))) while (null != taskFuture && !taskFuture.isDone) { - if (ExecutionNodeStatus.isCompleted(task.getStatus)) { + if (!ExecutionNodeStatus.isCompleted(task.getStatus)) { Utils.tryAndWarn { val progressResponse = Utils.tryAndWarn(taskProgress(task.getTaskId)) val resourceResponse = Utils.tryAndWarn(buildResourceMap(task))