Revert "insertByTablet execute synchronize"

This reverts commit 24817a3.
thulab · Sep 21, 2023 · 4a98b5d · 4a98b5d
1 parent de052f3
commit 4a98b5d
Showing 1 changed file with 14 additions and 10 deletions.
diff --git a/iotdb-1.1/src/main/java/cn/edu/tsinghua/iot/benchmark/iotdb110/IoTDBSessionBase.java b/iotdb-1.1/src/main/java/cn/edu/tsinghua/iot/benchmark/iotdb110/IoTDBSessionBase.java
@@ -71,16 +71,20 @@ public IoTDBSessionBase(DBConfig dbConfig) {
 
   public Status insertOneBatchByTablet(IBatch batch) {
     Tablet tablet = genTablet(batch);
-    try {
-      if (config.isVECTOR()) {
-        sessionWrapper.insertAlignedTablet(tablet);
-      } else {
-        sessionWrapper.insertTablet(tablet);
-      }
-      return new Status(true);
-    } catch (IoTDBConnectionException | StatementExecutionException e) {
-      return new Status(false, 0, e, e.toString());
-    }
+    future =
+        service.submit(
+            () -> {
+              try {
+                if (config.isVECTOR()) {
+                  sessionWrapper.insertAlignedTablet(tablet);
+                } else {
+                  sessionWrapper.insertTablet(tablet);
+                }
+              } catch (IoTDBConnectionException | StatementExecutionException e) {
+                LOGGER.error("insert tablet failed", e);
+              }
+            });
+    return waitFuture();
   }
 
   public Status insertOneBatchByRecord(IBatch batch) {