Each thread creates the table that it is responsible for.

thulab · Nov 28, 2024 · b6bc436 · b6bc436
1 parent fd3f210
commit b6bc436
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/...2.0/src/main/java/cn/edu/tsinghua/iot/benchmark/iotdb200/ModelStrategy/TableStrategy.java b/...2.0/src/main/java/cn/edu/tsinghua/iot/benchmark/iotdb200/ModelStrategy/TableStrategy.java
@@ -53,7 +53,6 @@
 public class TableStrategy extends IoTDBModelStrategy {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(TableStrategy.class);
-  protected static final Set<String> tables = new HashSet<>();
 
   public TableStrategy(DBConfig dbConfig) {
     super(dbConfig);
@@ -151,12 +150,7 @@ public Set<String> getAllTables(List<TimeseriesSchema> schemaList) {
     Set<String> tableNames = new HashSet<>();
     for (TimeseriesSchema timeseriesSchema : schemaList) {
       DeviceSchema schema = timeseriesSchema.getDeviceSchema();
-      synchronized (IoTDB.class) {
-        if (!tables.contains(schema.getTable())) {
-          tableNames.add(schema.getTable());
-          tables.add(schema.getTable());
-        }
-      }
+      tableNames.add(schema.getTable());
     }
     return tableNames;
   }