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 16:08:47 UTC
[incubator-iotdb] branch kyy updated: use transformed plan
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 8713bbc use transformed plan
8713bbc is described below
commit 8713bbc38e4c412e13a705534587a406c3b7867e
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Fri Jul 10 00:08:21 2020 +0800
use transformed plan
---
.../java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java | 1 +
1 file changed, 1 insertion(+)
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 f790cf0..6548ed1 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
@@ -1464,6 +1464,7 @@ public class MetaGroupMember extends RaftMember {
&& status.getCode() == TSStatusCode.TIMESERIES_NOT_EXIST.getStatusCode()
&& ClusterDescriptor.getInstance().getConfig().isEnableAutoCreateSchema()) {
// try to create timeseries
+ ((InsertPlan)plan).transformFailedPlan();
boolean hasCreate = autoCreateTimeseries((InsertPlan)plan);
if (hasCreate) {
status = forwardPlan(planGroupMap, plan);