[VL] Fix sort based shuffle oom in spill when compress was disabled (a…

…pache#7553) Co-authored-by: antmeta_antspark <[email protected]>
kecookier · Dec 13, 2024 · 67b6831 · 67b6831
1 parent 05b1e7a
commit 67b6831
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cpp/core/shuffle/rss/RssPartitionWriter.cc b/cpp/core/shuffle/rss/RssPartitionWriter.cc
@@ -85,7 +85,7 @@ arrow::Status RssPartitionWriter::doEvict(
       inMemoryPayload->toBlockPayload(
           payloadType, payloadPool_.get(), codec_ ? codec_.get() : nullptr, std::move(compressed)));
   // Copy payload to arrow buffered os.
-  ARROW_ASSIGN_OR_RAISE(auto rssBufferOs, arrow::io::BufferOutputStream::Create(options_.pushBufferMaxSize, pool_));
+  ARROW_ASSIGN_OR_RAISE(auto rssBufferOs, arrow::io::BufferOutputStream::Create(options_.pushBufferMaxSize));
   RETURN_NOT_OK(payload->serialize(rssBufferOs.get()));
   payload = nullptr; // Invalidate payload immediately.