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 b84c5a6 fix level compaction file not exist bug (#2061)
b84c5a6 is described below
commit b84c5a6272432ea97ea3df347a15a097432b36b5
Author: zhanglingzhe0820 <[email protected]>
AuthorDate: Tue Nov 17 18:39:13 2020 +0800
fix level compaction file not exist bug (#2061)
---
.../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()) {
