This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch ca_performance in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a7408c5d5ab3fae65f63f53c979a54fec0e56a16 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Wed Aug 2 12:16:54 2023 +0800 add shuffle Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../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
