You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/11/26 14:20:37 UTC
[iotdb] 01/01: Fix insert tablets npe
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch fix_tablets_statement
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7beac15122a374f701e4be5ee15fafe798244d2c
Author: HTHou <hh...@outlook.com>
AuthorDate: Sat Nov 26 22:20:21 2022 +0800
Fix insert tablets npe
---
server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java | 4 ----
2 files changed, 1 insertion(+), 5 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index fa8ea49ede..b8f6dde1ce 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -191,7 +191,7 @@ public class IoTDBConfig {
private int walBufferEntrySize = 16 * 1024;
/** Blocking queue capacity of each wal buffer */
- private int walBufferQueueCapacity = 50;
+ private int walBufferQueueCapacity = 5000;
/** Size threshold of each wal file. Unit: byte */
private volatile long walFileSizeThresholdInByte = 10 * 1024 * 1024;
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
index df62966e5e..bd85626786 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
@@ -232,13 +232,9 @@ public class StatementGenerator {
// construct insert statement
InsertMultiTabletsStatement insertStatement = new InsertMultiTabletsStatement();
List<InsertTabletStatement> insertTabletStatementList = new ArrayList<>();
- Map<String, PartialPath> devicePathMap = new HashMap<>();
for (int i = 0; i < req.prefixPaths.size(); i++) {
InsertTabletStatement insertTabletStatement = new InsertTabletStatement();
insertTabletStatement.setDevicePath(new PartialPath(req.prefixPaths.get(i)));
- insertTabletStatement.setDevicePath(
- devicePathMap.putIfAbsent(
- req.getPrefixPaths().get(i), new PartialPath(req.getPrefixPaths().get(i))));
insertTabletStatement.setMeasurements(req.measurementsList.get(i).toArray(new String[0]));
insertTabletStatement.setTimes(
QueryDataSetUtils.readTimesFromBuffer(req.timestampsList.get(i), req.sizeList.get(i)));