[incubator-linkis] branch dev-1.1.1 updated: Update ProgressProcessor.scala (#2010)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

peacewong pushed a commit to branch dev-1.1.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git


The following commit(s) were added to refs/heads/dev-1.1.1 by this push:
     new bf1930587 Update ProgressProcessor.scala (#2010)
bf1930587 is described below

commit bf19305874085b2ab7f5f9a59d0fb161e93b819a
Author: pengfeiwei <36...@users.noreply.github.com>
AuthorDate: Wed Apr 20 10:27:31 2022 +0800

    Update ProgressProcessor.scala (#2010)
    
    #2009 Resolve memory leaks
---
 .../computation/operation/progress/ProgressProcessor.scala             | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/operation/progress/ProgressProcessor.scala b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/operation/progress/ProgressProcessor.scala
index f543628e7..7386e7b9d 100644
--- a/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/operation/progress/ProgressProcessor.scala
+++ b/linkis-orchestrator/linkis-computation-orchestrator/src/main/scala/org/apache/linkis/orchestrator/computation/operation/progress/ProgressProcessor.scala
@@ -47,6 +47,7 @@ class ProgressProcessor(rootExecTaskId: String,
   }
 
   override def close(): Unit = {
-    this.progressObtainOperation
+    progressObtainOperation.removeLogProcessor(rootExecTaskId)
+    listeners.clear()
   }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org