This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch jenkins-disable-integration
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/jenkins-disable-integration by
this push:
new 7d27afcefc add more log
7d27afcefc is described below
commit 7d27afcefc9a190f63e49c7c31b0cc53b307789a
Author: xiangdong huang <[email protected]>
AuthorDate: Mon Dec 26 17:47:18 2022 +0800
add more log
---
.../org/apache/iotdb/db/utils/EnvironmentUtils.java | 17 ++++++++++++++---
server/src/test/resources/logback-test.xml | 1 +
2 files changed, 15 insertions(+), 3 deletions(-)
diff --git
a/server/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtils.java
b/server/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtils.java
index 3832331eeb..d7f2cc6a06 100644
--- a/server/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtils.java
+++ b/server/src/test/java/org/apache/iotdb/db/utils/EnvironmentUtils.java
@@ -101,8 +101,9 @@ public class EnvironmentUtils {
public static void cleanEnv() throws IOException, StorageEngineException {
// wait all compaction finished
+ logger.info("start to clean Env...");
CompactionTaskManager.getInstance().waitAllCompactionFinish();
-
+ logger.info("CompactionTaskManager finished...");
// deregister all user defined classes
try {
if (UDFManagementService.getInstance() != null) {
@@ -113,18 +114,26 @@ public class EnvironmentUtils {
}
logger.debug("EnvironmentUtil cleanEnv...");
- QueryResourceManager.getInstance().endQuery(TEST_QUERY_JOB_ID);
+ logger.info("start to end query...");
+ QueryResourceManager.getInstance().endQuery(TEST_QUERY_JOB_ID);
+ logger.info("start to closeAndRemoveAllOpenedReaders...");
// clear opened file streams
FileReaderManager.getInstance().closeAndRemoveAllOpenedReaders();
+ logger.info("check whether ports are closed...");
if (examinePorts) {
+ int total = 0;
// TODO: this is just too slow, especially on Windows, consider a better
way
boolean closed = examinePorts();
if (!closed) {
// sleep 10 seconds
try {
TimeUnit.SECONDS.sleep(10);
+ total++;
+ if (total % 2 == 0) {
+ logger.info("has wait {} seconds for closing ports", total * 10);
+ }
} catch (InterruptedException e) {
// do nothing
}
@@ -134,7 +143,7 @@ public class EnvironmentUtils {
}
}
}
-
+ logger.info("begin to clean...");
// clean wal manager
WALManager.getInstance().clear();
WALRecoverManager.getInstance().clear();
@@ -157,6 +166,7 @@ public class EnvironmentUtils {
BloomFilterCache.getInstance().clear();
}
+ logger.info("begin to close other info...");
// close array manager
PrimitiveArrayManager.close();
@@ -182,6 +192,7 @@ public class EnvironmentUtils {
throw new RuntimeException(e);
}
+ logger.info("begin to clean all dirs...");
// delete all directory
cleanAllDir();
config.setSeqTsFileSize(oldSeqTsFileSize);
diff --git a/server/src/test/resources/logback-test.xml
b/server/src/test/resources/logback-test.xml
index 0b287e4f69..8c3b497704 100644
--- a/server/src/test/resources/logback-test.xml
+++ b/server/src/test/resources/logback-test.xml
@@ -56,6 +56,7 @@
<logger name="io.moquette.broker.metrics.MQTTMessageLogger" level="ERROR"/>
<logger name="org.apache.iotdb.db.engine" level="INFO"/>
<logger name="COMPACTION" level="INFO"/>
+ <logger name="org.apache.iotdb.db.utils.EnvironmentUtils" level="INFO" />
<logger name="DETAILED_FAILURE_QUERY_TRACE" level="ERROR"/>
<root level="ERROR">
<appender-ref ref="stdout"/>