(iotdb) branch dev/1.3 updated: Fix NPE in Procedure's log (#16255) (#16278)

[yongzao]

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

yongzao pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new ad7ed924c4d Fix NPE in Procedure's log (#16255) (#16278)
ad7ed924c4d is described below

commit ad7ed924c4d9c96321c6046d8dc16e8ad0dd74a0
Author: Yongzao <yong...@apache.org>
AuthorDate: Wed Aug 27 09:42:18 2025 +0800

    Fix NPE in Procedure's log (#16255) (#16278)
---
 .../org/apache/iotdb/confignode/procedure/ProcedureExecutor.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
index 781dcdd030e..0d8368583b4 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java
@@ -803,17 +803,18 @@ public class ProcedureExecutor<Env> {
       // Check if any of the worker is stuck
       int runningCount = 0, stuckCount = 0;
       for (WorkerThread worker : workerThreads) {
-        if (worker.activeProcedure.get() == null) {
+        final Procedure<?> proc = worker.activeProcedure.get();
+        if (proc == null) {
           continue;
         }
         runningCount++;
         // WARN the worker is stuck
-        if (worker.getCurrentRunTime() < DEFAULT_WORKER_STUCK_THRESHOLD) {
+        if (worker.getCurrentRunTime() > DEFAULT_WORKER_STUCK_THRESHOLD) {
           stuckCount++;
           LOG.warn(
               "Worker stuck {}({}), run time {} ms",
               worker,
-              worker.activeProcedure.get().getProcType(),
+              proc.getProcType(),
               worker.getCurrentRunTime());
         }
         LOG.info(