Github user BJangir commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2097#discussion_r176946943
  
    --- Diff: 
core/src/main/java/org/apache/carbondata/core/writer/CarbonDeleteDeltaWriterImpl.java
 ---
    @@ -81,7 +80,9 @@ public CarbonDeleteDeltaWriterImpl(String filePath, 
FileFactory.FileType fileTyp
           if (null != dataOutStream) {
             dataOutStream.flush();
           }
    -      CarbonUtil.closeStreams(brWriter, dataOutStream);
    +      if (null != brWriter) {
    +        brWriter.close();
    +      }
    --- End diff --
    
    Fixed


---

Reply via email to