未验证 提交 16349e9a 编写于 作者: 周沛辰 提交者: GitHub

[IOTDB-2417]Cross compaction selector bug (#4853)

上级 9e9c548e
......@@ -132,25 +132,28 @@ public class InplaceCompactionSelector extends AbstractCrossSpaceCompactionSelec
// cached during selection
mergeResource.setCacheDeviceMeta(true);
AbstractCompactionTask compactionTask =
taskFactory.createTask(
logicalStorageGroupName,
virtualGroupId,
timePartition,
mergeResource,
storageGroupDir,
sequenceFileList,
unsequenceFileList,
mergeFiles[0],
mergeFiles[1],
fileSelector.getConcurrentMergeNum());
CompactionTaskManager.getInstance().addTaskToWaitingQueue(compactionTask);
taskSubmitted = true;
LOGGER.info(
"{} [Compaction] submit a task with {} sequence file and {} unseq files",
logicalStorageGroupName + "-" + virtualGroupId,
mergeResource.getSeqFiles().size(),
mergeResource.getUnseqFiles().size());
if (mergeFiles[0].size() > 0 && mergeFiles[1].size() > 0) {
AbstractCompactionTask compactionTask =
taskFactory.createTask(
logicalStorageGroupName,
virtualGroupId,
timePartition,
mergeResource,
storageGroupDir,
sequenceFileList,
unsequenceFileList,
mergeFiles[0],
mergeFiles[1],
fileSelector.getConcurrentMergeNum());
CompactionTaskManager.getInstance().addTaskToWaitingQueue(compactionTask);
taskSubmitted = true;
LOGGER.info(
"{} [Compaction] submit a task with {} sequence file and {} unseq files",
logicalStorageGroupName + "-" + virtualGroupId,
mergeResource.getSeqFiles().size(),
mergeResource.getUnseqFiles().size());
}
} catch (MergeException | IOException e) {
LOGGER.error("{} cannot select file for cross space compaction", logicalStorageGroupName, e);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册