This is an automated email from the ASF dual-hosted git repository. xuekaifeng pushed a commit to branch mlog_recover_log in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0cb910ad24a13a374de2f7a9f02f171f4dc0f5b2 Author: 151250176 <[email protected]> AuthorDate: Wed Oct 28 15:05:09 2020 +0800 fix log error --- server/src/main/java/org/apache/iotdb/db/metadata/MManager.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java index 98fa38b..f850353 100644 --- a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java +++ b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java @@ -325,7 +325,14 @@ public class MManager { } break; case MetadataOperationType.SET_STORAGE_GROUP: - setStorageGroup(new PartialPath(args[1])); + try { + setStorageGroup(new PartialPath(args[1])); + } + // two time series may set one storage group concurrently, + // that's normal in our concurrency control protocol + catch (MetadataException e){ + logger.info("concurrently operate set storage group cmd {} twice", cmd); + } break; case MetadataOperationType.DELETE_STORAGE_GROUP: deleteStorageGroups(Collections.singletonList(new PartialPath(args[1])));
