This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch fix-procedure-log
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fix-procedure-log by this push:
new 11f7257efe4 Update ProcedureExecutor.java
11f7257efe4 is described below
commit 11f7257efe423c8e2d4afe26a47c45ca8ac36dfa
Author: Yongzao <[email protected]>
AuthorDate: Mon Aug 25 18:03:21 2025 +0800
Update ProcedureExecutor.java
---
.../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(
