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

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


The following commit(s) were added to refs/heads/master by this push:
     new a3f1358  [IOTDB-1462] fix cross space compaction recover use wrong 
storage group name bug (#3496)
a3f1358 is described below

commit a3f1358e3b5c475523467bd2b18f4ade7b61427c
Author: Jialin Qiao <[email protected]>
AuthorDate: Sat Jul 3 03:49:50 2021 -0500

    [IOTDB-1462] fix cross space compaction recover use wrong storage group 
name bug (#3496)
---
 .../iotdb/db/engine/storagegroup/StorageGroupProcessor.java       | 2 +-
 .../java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java | 8 ++++++++
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 0487a34..bb3820e 100755
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -485,7 +485,7 @@ public class StorageGroupProcessor {
               tsFileManagement::mergeEndAction,
               taskName,
               IoTDBDescriptor.getInstance().getConfig().isForceFullMerge(),
-              logicalStorageGroupName + "-" + virtualStorageGroupId);
+              logicalStorageGroupName);
       logger.info(
           "{} - {} a RecoverMergeTask {} starts...",
           logicalStorageGroupName,
diff --git 
a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java 
b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java
index 76e0dba..499a2c9 100644
--- 
a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java
+++ 
b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java
@@ -34,6 +34,8 @@ import java.sql.ResultSet;
 import java.sql.Statement;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.TimeZone;
 
 import static org.apache.iotdb.db.constant.TestConstant.sum;
@@ -237,13 +239,19 @@ public class IoTDBGroupByMonthIT {
 
       Assert.assertTrue(hasResultSet);
       int cnt = 0;
+      List<String> times = new ArrayList<>();
       try (ResultSet resultSet = statement.getResultSet()) {
         while (resultSet.next()) {
           String ans = resultSet.getString(sum("root.sg1.d1.temperature"));
+          times.add(resultSet.getString("Time"));
           if (ans.equals("0.0")) {
             cnt++;
           }
         }
+        if (cnt < 28 || cnt > 31) {
+          System.out.println("cnt: " + cnt);
+          System.out.println(times);
+        }
         Assert.assertTrue(cnt >= 28);
         Assert.assertTrue(cnt <= 31);
       }

Reply via email to