You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/11/15 09:40:53 UTC
[iotdb] branch remove_todo updated: Remove more todo
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch remove_todo
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/remove_todo by this push:
new 9fa1edb6e1 Remove more todo
9fa1edb6e1 is described below
commit 9fa1edb6e17b4dff772aeea4fc6fd9a03029fd27
Author: HTHou <hh...@outlook.com>
AuthorDate: Tue Nov 15 17:40:42 2022 +0800
Remove more todo
---
.../src/test/java/org/apache/iotdb/db/it/IoTDBDeletionIT.java | 2 ++
.../java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java | 6 ++++++
2 files changed, 8 insertions(+)
diff --git a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBDeletionIT.java b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBDeletionIT.java
index faa3f90318..4600c0ddba 100644
--- a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBDeletionIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBDeletionIT.java
@@ -350,6 +350,7 @@ public class IoTDBDeletionIT {
String.format(insertTemplate, i, i, i, (double) i, "'" + i + "'", i % 2 == 0));
}
statement.executeBatch();
+ statement.clearBatch();
statement.execute("DELETE FROM root.vehicle.d0.s0 WHERE time > 150 and time <= 300");
statement.execute("DELETE FROM root.vehicle.d0.s0 WHERE time > 300 and time <= 400");
@@ -358,6 +359,7 @@ public class IoTDBDeletionIT {
String.format(insertTemplate, i, i, i, (double) i, "'" + i + "'", i % 2 == 0));
}
statement.executeBatch();
+ statement.clearBatch();
statement.execute("DELETE FROM root.vehicle.d0.s0 WHERE time > 500 and time <= 800");
statement.execute("DELETE FROM root.vehicle.d0.s0 WHERE time > 900 and time <= 1100");
statement.execute("DELETE FROM root.vehicle.d0.s0 WHERE time > 1500 and time <= 1650");
diff --git a/integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java b/integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java
index b7ff3957f8..7a07960490 100644
--- a/integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationIT.java
@@ -905,6 +905,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "true"));
}
statement.executeBatch();
+ statement.clearBatch();
statement.execute("flush");
for (int i = 7500; i < 8500; i++) {
@@ -913,6 +914,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "false"));
}
statement.executeBatch();
+ statement.clearBatch();
statement.execute("flush");
// prepare Unseq-File
for (int i = 500; i < 1500; i++) {
@@ -921,6 +923,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "true"));
}
statement.executeBatch();
+ statement.clearBatch();
statement.execute("flush");
for (int i = 3000; i < 6500; i++) {
statement.addBatch(
@@ -928,6 +931,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "false"));
}
statement.executeBatch();
+ statement.clearBatch();
// prepare BufferWrite cache
for (int i = 9000; i < 10000; i++) {
@@ -936,6 +940,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "true"));
}
statement.executeBatch();
+ statement.clearBatch();
// prepare Overflow cache
for (int i = 2000; i < 2500; i++) {
statement.addBatch(
@@ -943,6 +948,7 @@ public class IoTDBAggregationIT {
Locale.ENGLISH, insertTemplate, i, i, i, (double) i, "'" + i + "'", "false"));
}
statement.executeBatch();
+ statement.clearBatch();
for (String sql : dataSet3) {
statement.execute(sql);