This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch rel/0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.12 by this push:
     new 07c9ad0  [To rel/0.12] [IOTDB-1741] Avoid double close in level 
compaction execution (#4037)
07c9ad0 is described below

commit 07c9ad0a95cf65b15ec0d3d10ecc64091d3407af
Author: liuxuxin <[email protected]>
AuthorDate: Mon Sep 27 16:44:47 2021 +0800

    [To rel/0.12] [IOTDB-1741] Avoid double close in level compaction execution 
(#4037)
---
 .../org/apache/iotdb/db/engine/compaction/utils/CompactionUtils.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 7eb7e46..714fdc2 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
@@ -431,7 +431,10 @@ public class CompactionUtils {
       writer.endFile();
       targetResource.close();
     } finally {
-      writer.close();
+      if (writer.canWrite()) {
+        // avoid double close
+        writer.close();
+      }
       for (TsFileSequenceReader reader : tsFileSequenceReaderMap.values()) {
         reader.close();
       }

Reply via email to