You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/07/09 05:30:51 UTC

[incubator-iotdb] branch kyy updated: remove backup

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

yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/kyy by this push:
     new a975060  remove backup
a975060 is described below

commit a9750609c6be657597da5d629170c7c85751e715
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Thu Jul 9 13:30:25 2020 +0800

    remove backup
---
 .../org/apache/iotdb/cluster/server/member/MetaGroupMember.java     | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
index aea1b36..f790cf0 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
@@ -1449,10 +1449,6 @@ public class MetaGroupMember extends RaftMember {
    * @return
    */
   TSStatus forwardPlan(Map<PhysicalPlan, PartitionGroup> planGroupMap, PhysicalPlan plan) {
-//    InsertPlan backup = null;
-//    if (plan instanceof InsertPlan) {
-//      backup = (InsertPlan) ((InsertPlan) plan).clone();
-//    }
     // the error codes from the groups that cannot execute the plan
     TSStatus status;
     if (planGroupMap.size() == 1) {
@@ -1470,7 +1466,7 @@ public class MetaGroupMember extends RaftMember {
       // try to create timeseries
       boolean hasCreate = autoCreateTimeseries((InsertPlan)plan);
       if (hasCreate) {
-        status = forwardPlan(planGroupMap, (InsertPlan)plan);
+        status = forwardPlan(planGroupMap, plan);
       } else {
         logger.error("{}, Cannot auto create timeseries.", thisNode);
       }