You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2025/10/16 08:05:29 UTC
(iotdb) 01/01: Fix IoTDBClusterNodeShutdownHookIT
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch fix_IoTDBClusterNodeShutdownHookIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e490686eebd4dbad85a8f5d8da38202616cf4d08
Author: jt <jt...@163.com>
AuthorDate: Thu Oct 16 16:01:19 2025 +0800
Fix IoTDBClusterNodeShutdownHookIT
---
.../java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java | 2 ++
.../iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java | 2 +-
.../src/test/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java | 3 +++
3 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java
index 5fee09552b6..a0795076921 100644
--- a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java
+++ b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java
@@ -558,6 +558,7 @@ public abstract class AbstractNodeWrapper implements BaseNodeWrapper {
Thread.currentThread().interrupt();
logger.error("Waiting node to shutdown error.", e);
}
+ logger.info("In test {} {} stopped.", getTestLogDirName(), getId());
}
@Override
@@ -571,6 +572,7 @@ public abstract class AbstractNodeWrapper implements BaseNodeWrapper {
Thread.currentThread().interrupt();
logger.error("Waiting node to shutdown error.", e);
}
+ logger.info("In test {} {} started forcibly.", getTestLogDirName(), getId());
}
@Override
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java
index 176c6d78ce2..8917f163557 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java
@@ -47,7 +47,7 @@ public class IoTDBClusterNodeShutdownHookIT {
private static final String testConsensusProtocolClass = ConsensusFactory.RATIS_CONSENSUS;
- private static final int testConfigNodeNum = 2;
+ private static final int testConfigNodeNum = 3;
private static final int testDataNodeNum = 1;
@BeforeClass
diff --git a/integration-test/src/test/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java b/integration-test/src/test/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java
index 17e20d91e9a..31981f87270 100644
--- a/integration-test/src/test/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java
+++ b/integration-test/src/test/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java
@@ -58,6 +58,9 @@ public class IoTDBTestRunner extends BlockJUnit4ClassRunner {
EnvFactory.getEnv().setTestMethodName(description.getMethodName());
}
MultiEnvFactory.setTestMethodName(description.getMethodName());
+ if (Thread.currentThread().getName().equals("main")) {
+ Thread.currentThread().setName("main-" + description.getMethodName());
+ }
super.runChild(method, notifier);
final double timeCost = (System.currentTimeMillis() - currentTime) / 1000.0;
final String testName = description.getClassName() + "." + description.getMethodName();