This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch DataMigration in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 08f0d96a53d689d217be1dff710bed1eeffcb01a Author: HTHou <[email protected]> AuthorDate: Mon Jun 28 13:37:46 2021 +0800 Fix DataMigrationExample OOM if migrate too many timeseries --- .../src/main/java/org/apache/iotdb/DataMigrationExample.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java b/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java index 4ef8b10..251a36e 100644 --- a/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java +++ b/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java @@ -89,7 +89,7 @@ public class DataMigrationExample { int count = 0; while (schemaIter.next()) { count++; - Path currentPath = new Path(schemaIter.getString("timeseries")); + Path currentPath = new Path(schemaIter.getString("timeseries"), true); Future future = executorService.submit( new LoadThread( @@ -122,14 +122,14 @@ public class DataMigrationExample { this.measurement = series.getMeasurement(); this.dataType = dataType; this.series = series; - List<IMeasurementSchema> schemaList = new ArrayList<>(); - schemaList.add(new MeasurementSchema(measurement, dataType)); - tablet = new Tablet(device, schemaList, 300000); } @Override public Void call() { + List<IMeasurementSchema> schemaList = new ArrayList<>(); + schemaList.add(new MeasurementSchema(measurement, dataType)); + tablet = new Tablet(device, schemaList, 300000); SessionDataSetWrapper dataSet = null; try {
