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 <[email protected]>
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);