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 2020/11/17 10:41:11 UTC
[iotdb] 03/03: fix compaction file not exist but
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8b38d61a7d76e2885392b73f84866ed56c08c820
Author: qiaojialin <64...@qq.com>
AuthorDate: Tue Nov 17 18:40:39 2020 +0800
fix compaction file not exist but
---
.../org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java
index a2ef1fe..d44234f 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java
@@ -198,6 +198,9 @@ public class CompactionUtils {
for (TsFileResource levelResource : tsFileResources) {
TsFileSequenceReader reader = buildReaderFromTsFileResource(levelResource,
tsFileSequenceReaderMap, storageGroup);
+ if (reader == null) {
+ continue;
+ }
Map<String, List<ChunkMetadata>> chunkMetadataMap = reader
.readChunkMetadataInDevice(device);
for (Entry<String, List<ChunkMetadata>> entry : chunkMetadataMap.entrySet()) {