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

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new aecbd40   Fix mlog recover log level (#1883)
aecbd40 is described below

commit aecbd40f02eb5028ac291a0dd125a263c540ed53
Author: SilverNarcissus <[email protected]>
AuthorDate: Wed Oct 28 16:54:08 2020 +0800

     Fix mlog recover log level (#1883)
---
 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])));

Reply via email to