This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch DataMigration11 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1fd3393349d767aab2359aaed48a311564f16efa Author: HTHou <[email protected]> AuthorDate: Mon Jun 28 22:07:26 2021 +0800 [To rel/0.11] 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 ccb878d..f984567 100644 --- a/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java +++ b/example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java @@ -88,7 +88,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(count, currentPath, TSDataType.valueOf(schemaIter.getString("dataType")))); futureList.add(future); @@ -120,14 +120,14 @@ public class DataMigrationExample { this.measurement = series.getMeasurement(); this.dataType = dataType; this.series = series; - List<MeasurementSchema> schemaList = new ArrayList<>(); - schemaList.add(new MeasurementSchema(measurement, dataType)); - tablet = new Tablet(device, schemaList, 300000); } @Override public Void call() { + List<MeasurementSchema> schemaList = new ArrayList<>(); + schemaList.add(new MeasurementSchema(measurement, dataType)); + tablet = new Tablet(device, schemaList, 300000); SessionDataSetWrapper dataSet = null; try {
