This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch fix_cluster_stackoverflow in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba99dddda7ed8f8f511d86abc0e3819d8804b901 Author: LebronAl <[email protected]> AuthorDate: Mon Mar 29 15:10:30 2021 +0800 fix --- .../main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java | 1 + cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java | 3 +++ 2 files changed, 4 insertions(+) diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java index e8be569..3c305a8 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java @@ -291,6 +291,7 @@ public class Coordinator { } catch (MetadataException e) { logger.error("Cannot route plan {}", plan, e); } + logger.debug("route plan {} with partitionGroup {}", plan, planGroupMap); return planGroupMap; } diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java b/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java index 5038aa5..6e706cc 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java @@ -619,6 +619,9 @@ public class CMManager extends MManager { PartitionGroup partitionGroup = metaGroupMember.getPartitionTable().route(storageGroupName.getFullPath(), 0); List<String> unregisteredSeriesList = getUnregisteredSeriesList(seriesList, partitionGroup); + if (unregisteredSeriesList.isEmpty()) { + return true; + } logger.debug("Unregisterd series of {} are {}", seriesList, unregisteredSeriesList); return createTimeseries(unregisteredSeriesList, seriesList, insertPlan);
