fix tests

cluster/src/main/java/org/apache/iotdb/cluster/partition/PartitionTable.java

@@ -30,6 +30,7 @@
 import org.apache.iotdb.cluster.log.logtypes.PhysicalPlanLog;
 import org.apache.iotdb.cluster.rpc.thrift.Node;
 import org.apache.iotdb.cluster.utils.PartitionUtils;
+import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.engine.StorageEngine;
 import org.apache.iotdb.db.exception.metadata.MetadataException;
 import org.apache.iotdb.db.exception.metadata.StorageGroupNotSetException;
@@ -49,7 +50,6 @@
 public interface PartitionTable {
   // static final is not necessary, it is redundant for an interface
   Logger logger = LoggerFactory.getLogger(SlotPartitionTable.class);
-  long PARTITION_INTERVAL = StorageEngine.getTimePartitionInterval();
 
   /**
    * Given the storageGroupName and the timestamp, return the list of nodes on which the storage
@@ -181,8 +181,9 @@ default  MultiKeyMap<Long, PartitionGroup> partitionByPathRangeTime(String path,
       long startTime, long endTime) throws StorageGroupNotSetException {
     MultiKeyMap<Long, PartitionGroup> timeRangeMapRaftGroup = new MultiKeyMap<>();
     String storageGroup = MManager.getInstance().getStorageGroupNameByPath(path);
+    long partitionInterval = IoTDBDescriptor.getInstance().getConfig().getPartitionInterval();
     while (startTime <= endTime) {
-      long nextTime = (startTime / PARTITION_INTERVAL + 1) * PARTITION_INTERVAL; //FIXME considering the time unit
+      long nextTime = (startTime / partitionInterval + 1) * partitionInterval; //FIXME considering the time unit
       timeRangeMapRaftGroup.put(startTime, Math.min(nextTime - 1, endTime),
           this.route(storageGroup, startTime));
       startTime = nextTime;

cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java

@@ -297,7 +297,8 @@ private boolean isFileAlreadyPulled(RemoteTsFileResource resource) {
     // TODO-Cluster#352: The problem of duplicated data in remote files is partially resolved by
     //  tracking the merge history using the version numbers of the merged files. But a better
     //  solution still remains to be found.
-    String[] pathSegments = resource.getFile().getAbsolutePath().split(File.separator);
+    String separatorString = File.separator.equals("\\") ? "\\\\" : "/";
+    String[] pathSegments = resource.getFile().getAbsolutePath().split(separatorString);
     int segSize = pathSegments.length;
     // {storageGroupName}/{fileName}
     String storageGroupName = pathSegments[segSize - 2];
@@ -341,7 +342,8 @@ private void loadRemoteFile(RemoteTsFileResource resource) {
 
   private void loadRemoteResource(RemoteTsFileResource resource) {
     // remote/{nodeIdentifier}/{storageGroupName}/{fileName}
-    String[] pathSegments = resource.getFile().getAbsolutePath().split(File.separator);
+    String separatorString = File.separator.equals("\\") ? "\\\\" : "/";
+    String[] pathSegments = resource.getFile().getAbsolutePath().split(separatorString);
     int segSize = pathSegments.length;
     String storageGroupName = pathSegments[segSize - 2];
     File remoteModFile =
@@ -365,7 +367,8 @@ private void loadRemoteResource(RemoteTsFileResource resource) {
   private File pullRemoteFile(RemoteTsFileResource resource, Node node) {
     logger.debug("{}: pulling remote file {} from {}", name, resource, node);
 
-    String[] pathSegments = resource.getFile().getAbsolutePath().split(File.separator);
+    String separatorString = File.separator.equals("\\") ? "\\\\" : "/";
+    String[] pathSegments = resource.getFile().getAbsolutePath().split(separatorString);
     int segSize = pathSegments.length;
     // remote/{nodeIdentifier}/{storageGroupName}/{fileName}
     String tempFileName =

cluster/src/test/java/org/apache/iotdb/cluster/common/TestRemoteFileSnapshot.java

@@ -58,7 +58,7 @@ public void getRemoteSnapshot() {
     int startTime = 12345;
     for (RemoteTsFileResource tsFileResource : remoteDataFiles) {
       // fake a file for each resource
-      String[] splits = tsFileResource.getFile().getPath().split(File.separator);
+      String[] splits = tsFileResource.getFile().getPath().split("\\\\");
       String storageGroup = splits[splits.length - 2];
       InsertPlan insertPlan = new InsertPlan();
       insertPlan.setDeviceId(storageGroup);

cluster/src/test/java/org/apache/iotdb/cluster/common/TestUtils.java

@@ -67,7 +67,7 @@ public static PartitionTable getPartitionTable(int nodeNum) {
     for (int i = 0; i < nodeNum; i++) {
       nodes.add(getNode(i));
     }
-    return new SlotPartitionTable(nodes, getNode(0));
+    return new SlotPartitionTable(nodes, getNode(0), 100);
   }
 
   public static String getTestSg(int i) {

cluster/src/test/java/org/apache/iotdb/cluster/log/log/manage/FilePartitionedSnapshotLogManagerTest.java

@@ -60,7 +60,7 @@ public void testSnapshot() throws QueryProcessException, StorageGroupNotSetExcep
     manager.commitLog(10);
 
     // create files for sgs
-    for (int i = 0; i < 3; i++) {
+    for (int i = 1; i < 4; i++) {
       String sg = TestUtils.getTestSg(i);
       for (int j = 0; j < 4; j++) {
         // closed files
@@ -73,7 +73,7 @@ public void testSnapshot() throws QueryProcessException, StorageGroupNotSetExcep
 
     manager.takeSnapshot();
     PartitionedSnapshot snapshot = (PartitionedSnapshot) manager.getSnapshot();
-    for (int i = 0; i < 3; i++) {
+    for (int i = 1; i < 4; i++) {
       FileSnapshot fileSnapshot =
           (FileSnapshot) snapshot.getSnapshot(PartitionUtils.calculateStorageGroupSlot(
               TestUtils.getTestSg(i), 0, 100));

cluster/src/test/java/org/apache/iotdb/cluster/log/manage/FilePartitionedSnapshotLogManagerTest.java

@@ -59,7 +59,7 @@ public void testSnapshot() throws QueryProcessException, StorageGroupNotSetExcep
     manager.commitLog(10);
 
     // create files for sgs
-    for (int i = 0; i < 3; i++) {
+    for (int i = 1; i < 4; i++) {
       String sg = TestUtils.getTestSg(i);
       for (int j = 0; j < 4; j++) {
         // closed files
@@ -72,7 +72,7 @@ public void testSnapshot() throws QueryProcessException, StorageGroupNotSetExcep
 
     manager.takeSnapshot();
     PartitionedSnapshot snapshot = (PartitionedSnapshot) manager.getSnapshot();
-    for (int i = 0; i < 3; i++) {
+    for (int i = 1; i < 4; i++) {
       FileSnapshot fileSnapshot =
           (FileSnapshot) snapshot.getSnapshot(PartitionUtils.calculateStorageGroupSlot(
               TestUtils.getTestSg(i), 0, 100));

cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterPhysicalGeneratorTest.java

@@ -47,19 +47,17 @@ public void setUp() throws MetadataException {
   @Test
   public void test() throws QueryProcessException {
     QueryOperator operator = new QueryOperator(SQLConstant.TOK_QUERY);
-    operator.setGroupByDevice(true);
 
     SelectOperator selectOperator = new SelectOperator(SQLConstant.TOK_SELECT);
-    selectOperator.setSuffixPathList(Collections.singletonList(new Path("*")));
+    selectOperator.setSuffixPathList(pathList);
     FromOperator fromOperator = new FromOperator(SQLConstant.TOK_FROM);
     fromOperator.addPrefixTablePath(new Path(TestUtils.getTestSg(0)));
 
     operator.setSelectOperator(selectOperator);
     operator.setFromOperator(fromOperator);
     QueryPlan plan = (QueryPlan) physicalGenerator.transformToPhysicalPlan(operator);
 
-    // TODO: Enable this when IOTDB-412 is fixed
-    //assertEquals(pathList, plan.getDeduplicatedPaths());
+    assertEquals(pathList, plan.getDeduplicatedPaths());
     assertEquals(dataTypes, plan.getDeduplicatedDataTypes());
   }
 }