You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2020/12/31 08:06:46 UTC
[iotdb] branch virtual_partition_2_merge updated: fix bug
This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a commit to branch virtual_partition_2_merge
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/virtual_partition_2_merge by this push:
new 9864271 fix bug
9864271 is described below
commit 986427122b66e3b7006a2944e2d379d1e75adb1c
Author: 151250176 <15...@smail.nju.edu.cn>
AuthorDate: Thu Dec 31 16:06:22 2020 +0800
fix bug
---
.../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 461c305..7906220 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -1042,7 +1042,7 @@ public class StorageGroupProcessor {
TsFileProcessor tsFileProcessor;
VersionController versionController = getVersionControllerByTimePartitionId(timePartitionId);
if (sequence) {
- tsFileProcessor = new TsFileProcessor(storageGroupName,
+ tsFileProcessor = new TsFileProcessor(logicalStorageGroupName + File.separator + storageGroupName,
fsFactory.getFileWithParent(filePath), storageGroupInfo,
versionController, this::closeUnsealedTsFileProcessorCallBack,
this::updateLatestFlushTimeCallback, true);
@@ -1054,7 +1054,7 @@ public class StorageGroupProcessor {
.getTsFileResource().calculateRamSize());
}
} else {
- tsFileProcessor = new TsFileProcessor(storageGroupName,
+ tsFileProcessor = new TsFileProcessor(logicalStorageGroupName + File.separator + storageGroupName,
fsFactory.getFileWithParent(filePath), storageGroupInfo,
versionController, this::closeUnsealedTsFileProcessorCallBack,
this::unsequenceFlushCallback, false);