You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2021/07/08 05:40:38 UTC
[iotdb] branch master updated: [IOTDB-1471] Fix path not right in
"sg may not ready" log (#3524)
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 18ae729 [IOTDB-1471] Fix path not right in "sg may not ready" log (#3524)
18ae729 is described below
commit 18ae729e2792c709b7054cb0de25f4d331d7558e
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Thu Jul 8 00:40:07 2021 -0500
[IOTDB-1471] Fix path not right in "sg may not ready" log (#3524)
---
server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java | 3 +--
.../db/engine/storagegroup/virtualSg/VirtualStorageGroupManager.java | 4 +++-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index 711256c..a33906c 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -445,8 +445,7 @@ public class StorageEngine implements IService {
if (virtualStorageGroupManager == null) {
// if finish recover
if (isAllSgReady.get()) {
- waitAllSgReady(devicePath);
- synchronized (storageGroupMNode) {
+ synchronized (this) {
virtualStorageGroupManager = processorMap.get(storageGroupMNode.getPartialPath());
if (virtualStorageGroupManager == null) {
virtualStorageGroupManager = new VirtualStorageGroupManager();
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/VirtualStorageGroupManager.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/VirtualStorageGroupManager.java
index e4faadb..460342b 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/VirtualStorageGroupManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/VirtualStorageGroupManager.java
@@ -116,7 +116,9 @@ public class VirtualStorageGroupManager {
} else {
// not finished recover, refuse the request
throw new StorageEngineException(
- "the sg " + partialPath + " may not ready now, please wait and retry later",
+ "the sg "
+ + storageGroupMNode.getFullPath()
+ + " may not ready now, please wait and retry later",
TSStatusCode.STORAGE_GROUP_NOT_READY.getStatusCode());
}
}