Merge pull request #18891 from jakesmith/HPCC-32267-suppress_rw_buffe…

…red_if_compressed HPCC-32267 Suppress buffer io if compressed in write stream Reviewed-by: Gavin Halliday <[email protected]> Merged-by: Gavin Halliday <[email protected]>
hpcc-systems · Jul 18, 2024 · 74bd12f · 74bd12f
2 parents 4a2ee9a + c6413d4
commit 74bd12f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/common/thorhelper/thorcommon.cpp b/common/thorhelper/thorcommon.cpp
@@ -1647,7 +1647,10 @@ IExtRowWriter *createRowWriter(IFile *iFile, IRowInterfaces *rowIf, unsigned fla
 {
     OwnedIFileIO iFileIO;
     if (TestRwFlag(flags, rw_compress))
+    {
+        flags &= ~rw_buffered; // if compressed, do not want buffered stream as well
         iFileIO.setown(createCompressedFileWriter(iFile, rowIf, flags, compressor, compressorBlkSz));
+    }
     else
         iFileIO.setown(iFile->open((flags & rw_extend)?IFOwrite:IFOcreate));
     if (!iFileIO)