[inlong] branch master updated: [INLONG-6707][Sort] Delay the release of audit metrics (#6712)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 86cc7aeb2 [INLONG-6707][Sort] Delay the release of audit metrics 
(#6712)
86cc7aeb2 is described below

commit 86cc7aeb26f32375680260feb92dba3aa5816104
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Fri Dec 2 23:23:20 2022 +0800

    [INLONG-6707][Sort] Delay the release of audit metrics (#6712)
---
 .../src/main/java/org/apache/inlong/sort/standalone/SortCluster.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/SortCluster.java
 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/SortCluster.java
index 4b52006c5..a36a40a84 100644
--- 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/SortCluster.java
+++ 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/SortCluster.java
@@ -38,7 +38,6 @@ import java.util.concurrent.ConcurrentHashMap;
 import static 
org.apache.inlong.sort.standalone.utils.Constants.RELOAD_INTERVAL;
 
 /**
- * 
  * SortCluster
  */
 public class SortCluster {
@@ -123,6 +122,7 @@ public class SortCluster {
                 this.taskMap.put(newTaskName, newTask);
             }
             // remove task
+            deletingTasks.clear();
             for (Entry<String, SortTask> entry : taskMap.entrySet()) {
                 String taskName = entry.getKey();
                 boolean isFound = false;
@@ -141,7 +141,6 @@ public class SortCluster {
                 task.stop();
                 taskMap.remove(task.getTaskName());
             }
-            deletingTasks.clear();
         } catch (Throwable e) {
             LOG.error(e.getMessage(), e);
         }