insertByTablet execute synchronize

thulab · Sep 21, 2023 · 24817a3 · 24817a3
1 parent 02e8b02
commit 24817a3
Showing 1 changed file with 10 additions and 14 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,20 +71,16 @@ public IoTDBSessionBase(DBConfig dbConfig) {
 
   public Status insertOneBatchByTablet(IBatch batch) {
     Tablet tablet = genTablet(batch);
-    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();
+    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());
+    }
   }
 
   public Status insertOneBatchByRecord(IBatch batch) {