[iotdb] branch ca-0801 created (now 252315a32d1)

[ja...@apache.org]

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

jackietien pushed a change to branch ca-0801
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 252315a32d1 do shuffle about fi

This branch includes the following new commits:

     new 252315a32d1 do shuffle about fi

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: do shuffle about fi

[ja...@apache.org]

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

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

commit 252315a32d10bdb66381808a9bb0b46e105173eb
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Aug 1 09:44:11 2023 +0800

    do shuffle about fi
---
 .../db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java
index 61949962285..72ad5990157 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/InsertRowsNode.java
@@ -37,6 +37,7 @@ import java.io.DataOutputStream;
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -229,7 +230,9 @@ public class InsertRowsNode extends InsertNode {
     }
     analysis.setRedirectNodeList(redirectInfo);
 
-    return new ArrayList<>(splitMap.values());
+    List<WritePlanNode> res = new ArrayList<>(splitMap.values());
+    Collections.shuffle(res);
+    return res;
   }
 
   @Override