[iotdb] branch fix_tablets_statement created (now 7beac15122)

[ha...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a change to branch fix_tablets_statement
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 7beac15122 Fix insert tablets npe

This branch includes the following new commits:

     new 7beac15122 Fix insert tablets npe

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: Fix insert tablets npe

[ha...@apache.org]

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)));