From c6413d4a5424eefa54eb00707f73959b033f1805 Mon Sep 17 00:00:00 2001
From: Jake Smith <jake.smith@lexisnexisrisk.com>
Date: Wed, 17 Jul 2024 17:36:03 +0100
Subject: [PATCH] HPCC-32267 Suppress buffer io if compressed in write stream

Signed-off-by: Jake Smith <jake.smith@lexisnexisrisk.com>
---
 common/thorhelper/thorcommon.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/common/thorhelper/thorcommon.cpp b/common/thorhelper/thorcommon.cpp
index 38f29328615..82bfa6b785e 100644
--- 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)