[iotdb] branch remove_todo updated: Remove more todo

[haonan]

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 <hhao...@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);