From 5e7e9896c3e87ab37c7f6b5a3769a8c057fb9c82 Mon Sep 17 00:00:00 2001
From: Hongze Zhang <hongze.zhang@intel.com>
Date: Mon, 10 Jan 2022 13:03:21 +0800
Subject: [PATCH] [NSE-684] BufferedOutputStream causes massive futex system
 calls

---
 native-sql-engine/cpp/src/shuffle/splitter.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/native-sql-engine/cpp/src/shuffle/splitter.cc b/native-sql-engine/cpp/src/shuffle/splitter.cc
index fa99532ac..a640ee958 100644
--- a/native-sql-engine/cpp/src/shuffle/splitter.cc
+++ b/native-sql-engine/cpp/src/shuffle/splitter.cc
@@ -437,7 +437,7 @@ arrow::Status Splitter::Stop() {
   ARROW_ASSIGN_OR_RAISE(fout,
                         arrow::io::FileOutputStream::Open(options_.data_file, true));
   if (options_.buffered_write) {
-    ARROW_ASSIGN_OR_RAISE(data_file_os_, arrow::io::BufferedOutputStream::Create(
+    ARROW_ASSIGN_OR_RAISE(data_file_os_, arrow::io::UnlockedBufferedOutputStream::Create(
                                              16384, options_.memory_pool, fout));
   } else {
     data_file_os_ = fout;