[iotdb] branch cluster_auto_create_schema created (now 694ade1)

[ta...@apache.org]

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

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


      at 694ade1  fix retry logic

This branch includes the following new commits:

     new 694ade1  fix retry logic

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 retry logic

[ta...@apache.org]

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 <TX...@gmail.com>
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);