[iotdb] branch master updated: [IOTDB-4177] Fix INSERT Failed when using SESSION_BY_RECORDS (#7043)

[jackietien]

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

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new adc46576f8 [IOTDB-4177] Fix INSERT Failed when using 
SESSION_BY_RECORDS (#7043)
adc46576f8 is described below

commit adc46576f86f025658272e3d2146d6d38939b081
Author: Haonan <hhao...@outlook.com>
AuthorDate: Thu Aug 18 14:16:06 2022 +0800

    [IOTDB-4177] Fix INSERT Failed when using SESSION_BY_RECORDS (#7043)
---
 .../java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java 
b/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
index 0a00f75665..1d4a8956df 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
@@ -977,8 +977,8 @@ public class LocalConfigNode {
         // use an empty dataPartitionMap to init DataPartition
         if (dataRegionId != null) {
           Map<TTimePartitionSlot, List<TRegionReplicaSet>> 
timePartitionToRegionsMap =
-              new HashMap<>();
-
+              deviceToRegionsMap.getOrDefault(
+                  executor.getSeriesPartitionSlot(deviceId), new HashMap<>());
           timePartitionToRegionsMap.put(
               new TTimePartitionSlot(STANDALONE_MOCK_TIME_SLOT_START_TIME),
               Collections.singletonList(
@@ -1031,7 +1031,8 @@ public class LocalConfigNode {
         DataRegionId dataRegionId =
             getBelongedDataRegionIdWithAutoCreate(new PartialPath(deviceId));
         Map<TTimePartitionSlot, List<TRegionReplicaSet>> 
timePartitionToRegionsMap =
-            new HashMap<>();
+            deviceToRegionsMap.getOrDefault(
+                executor.getSeriesPartitionSlot(deviceId), new HashMap<>());
         for (TTimePartitionSlot timePartitionSlot :
             dataPartitionQueryParam.getTimePartitionSlotList()) {
           // for each time partition