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

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


The following commit(s) were added to refs/heads/cluster_new by this push:
     new a6a97ea  fix autoCreateSchema bug
     new 2bca330  Merge pull request #1575 from 
LebronAl/cluster_new_auto_create_bug
a6a97ea is described below

commit a6a97ea0863fa03129ea18ce28f8373bea89505a
Author: LebronAl <[email protected]>
AuthorDate: Tue Jul 28 20:48:26 2020 +0800

    fix autoCreateSchema bug
---
 .../java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 9155adb..ab13fc8 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
@@ -1770,7 +1770,7 @@ public class MetaGroupMember extends RaftMember {
     List<String> unregisteredSeriesList = 
getUnregisteredSeriesList(seriesList, partitionGroup);
     for (String seriesPath : unregisteredSeriesList) {
       int index = seriesList.indexOf(seriesPath);
-      TSDataType dataType = insertPlan.getDataTypes() != null
+      TSDataType dataType = (insertPlan.getDataTypes() != null && 
insertPlan.getDataTypes()[index] != null)
           ? insertPlan.getDataTypes()[index]
           : TypeInferenceUtils.getPredictedDataType(insertPlan instanceof 
InsertTabletPlan
               ? Array.get(((InsertTabletPlan) insertPlan).getColumns()[index], 
0)

Reply via email to