You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2021/01/19 12:30:06 UTC
[iotdb] 01/01: try to fix
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 <15...@smail.nju.edu.cn>
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()) {