You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2021/06/28 15:02:07 UTC
[iotdb] branch rel/0.11 updated: [To rel/0.11] Fix
DataMigrationExample OOM if migrate too many timeseries (#3464)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.11 by this push:
new 6b6bf34 [To rel/0.11] Fix DataMigrationExample OOM if migrate too many timeseries (#3464)
6b6bf34 is described below
commit 6b6bf349b8b0c848f7403d06f369f8fd4a57f236
Author: Haonan <hh...@outlook.com>
AuthorDate: Mon Jun 28 23:01:20 2021 +0800
[To rel/0.11] Fix DataMigrationExample OOM if migrate too many timeseries (#3464)
---
.../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 {