[incubator-iotdb] branch cluster updated: fix a bug of execute batch

[lt...@apache.org]

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

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


The following commit(s) were added to refs/heads/cluster by this push:
     new a3391f4  fix a bug of execute batch
a3391f4 is described below

commit a3391f413a054022ac9566b56908961ff2c20603
Author: lta <li...@163.com>
AuthorDate: Mon Apr 8 18:54:52 2019 +0800

    fix a bug of execute batch
---
 .../java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java b/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
index db86eb1..187fec4 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/entity/raft/DataStateMachine.java
@@ -116,7 +116,7 @@ public class DataStateMachine extends StateMachineAdapter {
           PhysicalPlan plan = PhysicalPlanLogTransfer.logToOperator(planByte);
 
           /** If the request is to set path and sg of the path doesn't exist, it needs to run null-read in meta group to avoid out of data sync **/
-          if (plan.getOperatorType() == OperatorType.CREATE_TIMESERIES && checkPathExistence(
+          if (plan.getOperatorType() == OperatorType.CREATE_TIMESERIES && !checkPathExistence(
               ((MetadataPlan) plan).getPath().getFullPath())) {
             SingleQPTask nullReadTask = new SingleQPTask(false, null);
             handleNullReadToMetaGroup(nullReadTask, status, nullReadTask);