Github user BJangir commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2097#discussion_r176946937
--- Diff:
core/src/main/java/org/apache/carbondata/core/writer/CarbonDeleteDeltaWriterImpl.java
---
@@ -110,7 +111,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
---