diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionSelector.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionSelector.java index 6190fb45c464c20ed1902db40fe9343db22d840a..691f1341c538208edb5419d768e0c2ac3058874e 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionSelector.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionSelector.java @@ -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); }