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

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

commit 166980e8e1851f6185ceec2b0baf8279b4776963
Author: 151250176 <[email protected]>
AuthorDate: Tue Jan 19 20:28:43 2021 +0800

    try to fix
---
 .../iotdb/db/integration/IoTDBRemovePartitionIT.java   | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git 
a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
 
b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
index 860ff45..a1d6771 100644
--- 
a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
+++ 
b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
@@ -83,6 +83,12 @@ public class IoTDBRemovePartitionIT {
 
   @Test
   public void testRemovePartialPartition() throws StorageEngineException, 
IllegalPathException {
+    try {
+      Thread.sleep(5000);
+    } catch (InterruptedException e) {
+      // do nothing
+    }
+
     StorageEngine.getInstance().removePartitions(new PartialPath("root.test1"),
         (storageGroupName, timePartitionId) -> timePartitionId >= 5);
     StorageEngine.getInstance().removePartitions(new PartialPath("root.test2"),
@@ -117,6 +123,12 @@ public class IoTDBRemovePartitionIT {
 
   @Test
   public void testRemoveAllPartition() throws StorageEngineException, 
IllegalPathException {
+    try {
+      Thread.sleep(5000);
+    } catch (InterruptedException e) {
+      // do nothing
+    }
+
     StorageEngine.getInstance().removePartitions(new PartialPath("root.test1"),
         (storageGroupName, timePartitionId) -> true);
 
@@ -133,6 +145,12 @@ public class IoTDBRemovePartitionIT {
 
   @Test
   public void testSQLRemovePartition() {
+    try {
+      Thread.sleep(5000);
+    } catch (InterruptedException e) {
+      // do nothing
+    }
+    
     try (Connection connection = DriverManager
         .getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", 
"root");
         Statement statement = connection.createStatement()) {

Reply via email to