You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2024/01/05 04:10:34 UTC

(iotdb) branch procedure_name created (now a593e000e12)

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

tanxinyu pushed a change to branch procedure_name
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at a593e000e12 finish

This branch includes the following new commits:

     new a593e000e12 finish

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



(iotdb) 01/01: finish

Posted by ta...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch procedure_name
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit a593e000e12c616c14255b383b725b43ca741b60
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Fri Jan 5 12:10:16 2024 +0800

    finish
    
    Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
 .../org/apache/iotdb/confignode/procedure/ProcedureExecutor.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 c9a20080473..ffc205dcbfc 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
@@ -828,7 +828,11 @@ public class ProcedureExecutor<Env> {
 
         // WARN the worker is stuck
         stuckCount++;
-        LOG.warn("Worker stuck {}, run time {} ms", worker, worker.getCurrentRunTime());
+        LOG.warn(
+            "Worker stuck {}({}), run time {} ms",
+            worker,
+            worker.activeProcedure.get().getProcType(),
+            worker.getCurrentRunTime());
       }
       return stuckCount;
     }