add logs

Author: jt2594838

integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java

@@ -128,6 +128,16 @@ public void normal1C3DTest() throws Exception {
               .build();
       session.open();
 
+      LOGGER.info(
+          "IoTDBRegionReconstructForIoTV1IT: Node {} is to be closed",
+          EnvFactory.getEnv().dataNodeIdToWrapper(dataNodeToBeClosed).get().getIpAndPortString());
+      LOGGER.info(
+          "IoTDBRegionReconstructForIoTV1IT: Node {} is to be reconstructed",
+          EnvFactory.getEnv()
+              .dataNodeIdToWrapper(dataNodeToBeReconstructed)
+              .get()
+              .getIpAndPortString());
+
       // delete one DataNode's data dir, stop another DataNode
       File dataDirToBeReconstructed =
           new File(
@@ -169,15 +179,15 @@ public void normal1C3DTest() throws Exception {
       try {
         Awaitility.await()
             .pollInterval(1, TimeUnit.SECONDS)
-            .atMost(1, TimeUnit.MINUTES)
+            .atMost(10, TimeUnit.MINUTES)
             .until(
                 () ->
                     getRegionStatusWithoutRunning(session).isEmpty()
                         && dataDirToBeReconstructed.getAbsoluteFile().exists());
       } catch (Exception e) {
         LOGGER.error(
             "Two factor: {} && {}",
-            getRegionStatusWithoutRunning(session).isEmpty(),
+            getRegionStatusWithoutRunning(session),
             dataDirToBeReconstructed.getAbsoluteFile().exists());
         fail();
       }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java

@@ -1977,6 +1977,10 @@ public void syncCloseWorkingTsFileProcessors(boolean sequence) {
 
   private void waitClosingTsFileProcessorFinished() throws InterruptedException {
     long startTime = System.currentTimeMillis();
+    logger.info(
+        "Start to wait TsFiles to close, seq files: {}, unseq files: {}",
+        closingSequenceTsFileProcessor,
+        closingUnSequenceTsFileProcessor);
     while (!closingSequenceTsFileProcessor.isEmpty()
         || !closingUnSequenceTsFileProcessor.isEmpty()) {
       synchronized (closeStorageGroupCondition) {
@@ -1991,6 +1995,10 @@ private void waitClosingTsFileProcessorFinished() throws InterruptedException {
             "{} has spent {}s to wait for closing all TsFiles.",
             databaseName + "-" + this.dataRegionId,
             (System.currentTimeMillis() - startTime) / 1000);
+        logger.warn(
+            "Sseq files: {}, unseq files: {}",
+            closingSequenceTsFileProcessor,
+            closingUnSequenceTsFileProcessor);
       }
     }
   }
@@ -2049,6 +2057,7 @@ public void forceCloseAllWorkingTsFileProcessors() throws TsFileProcessorExcepti
                 resource.getTsFile().getName());
       }
       WritingMetrics.getInstance().recordActiveTimePartitionCount(-1);
+      logger.info("{} files were closed", closedTsFileResources.size());
     } finally {
       writeUnlock();
     }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java

@@ -2334,4 +2334,9 @@ private void logFlushQueryReadUnlocked() {
           "{}: {} release flushQueryLock", dataRegionName, tsFileResource.getTsFile().getName());
     }
   }
+
+  @Override
+  public String toString() {
+    return "TsFileProcessor{" + "tsFileResource=" + tsFileResource + '}';
+  }
 }