Skip to content

Commit

Permalink
Use default memory pool when serialize payload
Browse files Browse the repository at this point in the history
  • Loading branch information
antmeta_antspark committed Oct 16, 2024
1 parent 3ca5f77 commit dde0932
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cpp/core/shuffle/rss/RssPartitionWriter.cc
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand Down

0 comments on commit dde0932

Please sign in to comment.