This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch cluster_auto_create_schema in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 694ade10887c57e8e38686746b2a7ee4fb420113 Author: LebronAl <[email protected]> AuthorDate: Wed Jul 7 18:58:43 2021 +0800 fix retry logic --- .../main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java index b46273a..1f1fd68 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java @@ -451,8 +451,7 @@ public class Coordinator { // e.g., an InsertTabletPlan contains 3 rows, row1 and row3 belong to NodeA and row2 // belongs to NodeB, when NodeA returns a success while NodeB returns a failure, the // failure and success should be placed into proper positions in TSStatus.subStatus - if (plan instanceof InsertTabletPlan - || plan instanceof InsertMultiTabletPlan + if (plan instanceof InsertMultiTabletPlan || plan instanceof CreateMultiTimeSeriesPlan || plan instanceof InsertRowsPlan) { status = forwardMultiSubPlan(planGroupMap, plan);
