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);
}