[incubator-iotdb] branch kyy3 updated: ignore exception

[yuyuankang]

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

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


The following commit(s) were added to refs/heads/kyy3 by this push:
     new 52b7ce4  ignore exception
52b7ce4 is described below

commit 52b7ce4cb57c232eed0f19e7f4a3c66464c37605
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Mon Jul 6 21:18:28 2020 +0800

    ignore exception
---
 .../org/apache/iotdb/cluster/query/ClusterPlanExecutor.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
index 9695807..4d62eec 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
@@ -61,6 +61,7 @@ import org.apache.iotdb.db.metadata.mnode.StorageGroupMNode;
 import org.apache.iotdb.db.qp.executor.PlanExecutor;
 import org.apache.iotdb.db.qp.physical.PhysicalPlan;
 import org.apache.iotdb.db.qp.physical.crud.AlignByDevicePlan;
+import org.apache.iotdb.db.qp.physical.crud.DeletePlan;
 import org.apache.iotdb.db.qp.physical.crud.InsertPlan;
 import org.apache.iotdb.db.qp.physical.crud.QueryPlan;
 import org.apache.iotdb.db.qp.physical.sys.AuthorPlan;
@@ -697,6 +698,17 @@ public class ClusterPlanExecutor extends PlanExecutor {
   }
 
   @Override
+  public void delete(DeletePlan deletePlan) throws QueryProcessException {
+    if (deletePlan.getPaths().isEmpty()) {
+      logger.info("TimeSeries list to be deleted is empty.");
+      return;
+    }
+    for (Path path : deletePlan.getPaths()) {
+      delete(path, deletePlan.getDeleteTime());
+    }
+  }
+
+  @Override
   public void delete(Path path, long timestamp) throws QueryProcessException {
     String deviceId = path.getDevice();
     String measurementId = path.getMeasurement();