Fix the issue that uuid is null in the log after execution

linkedin · Oct 3, 2024 · 5810600 · 5810600
1 parent 7b35568
commit 5810600
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java
@@ -1370,19 +1370,19 @@ public void run() {
         if (_executionTimerInvolveBrokerRemovalOrDemotion != null) {
           _executionTimerInvolveBrokerRemovalOrDemotion.update(duration, TimeUnit.MILLISECONDS);
         }
-
         String executionStatusString = String.format("task Id: %s; removed brokers: %s; demoted brokers: %s; total time used: %dms.",
                                                _uuid,
                                                _removedBrokers,
                                                _demotedBrokers,
                                                duration
                                                );
-
         if (_executionException != null) {
           LOG.info("Execution failed: {}. Exception: {}", executionStatusString, _executionException.getMessage());
         } else {
           LOG.info("Execution succeeded: {}. ", executionStatusString);
         }
+        // Clear completed execution.
+        clearCompletedExecution();
       }
     }
 
@@ -1494,8 +1494,6 @@ private void execute(UserTaskManager.UserTaskInfo userTaskInfo) {
         _executionException = t;
       } finally {
         notifyFinishedTask(userTaskInfo);
-        // Clear completed execution.
-        clearCompletedExecution();
       }
     }