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)