Skip to content

Commit 1fea546

Browse files
committed
[native] Use 'max_output_buffer_size' instead of 'max_arbitrary_buffer_size'
1 parent 2e0d73c commit 1fea546

2 files changed

Lines changed: 3 additions & 4 deletions

File tree

‎presto-native-execution/presto_cpp/main/common/Configs.cpp‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -735,8 +735,7 @@ BaseVeloxQueryConfig::BaseVeloxQueryConfig() {
735735
BOOL_PROP(
736736
QueryConfig::kPrestoArrayAggIgnoreNulls,
737737
c.prestoArrayAggIgnoreNulls()),
738-
NUM_PROP(
739-
QueryConfig::kMaxArbitraryBufferSize, c.maxArbitraryBufferSize()),
738+
NUM_PROP(QueryConfig::kMaxOutputBufferSize, c.maxOutputBufferSize()),
740739
};
741740
}
742741

@@ -755,7 +754,7 @@ void BaseVeloxQueryConfig::updateLoadedValues(
755754
const std::unordered_map<std::string, std::string> updatedValues{
756755
{QueryConfig::kPrestoArrayAggIgnoreNulls,
757756
bool2String(systemConfig->useLegacyArrayAgg())},
758-
{QueryConfig::kMaxArbitraryBufferSize,
757+
{QueryConfig::kMaxOutputBufferSize,
759758
systemConfig->capacityPropertyAsBytesString(
760759
SystemConfig::kSinkMaxBufferSize)},
761760
{QueryConfig::kMaxPartitionedOutputBufferSize,

‎presto-native-execution/presto_cpp/main/common/tests/BaseVeloxQueryConfigTest.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ TEST_F(BaseVeloxQueryConfigTest, fromSystemConfig) {
121121
cfg->initialize(configFilePath);
122122

123123
ASSERT_EQ("true", GET_VAL(QueryConfig::kPrestoArrayAggIgnoreNulls));
124-
ASSERT_EQ("17825792", GET_VAL(QueryConfig::kMaxArbitraryBufferSize));
124+
ASSERT_EQ("17825792", GET_VAL(QueryConfig::kMaxOutputBufferSize));
125125
ASSERT_EQ("6291456", GET_VAL(QueryConfig::kMaxPartitionedOutputBufferSize));
126126

127127
#undef GET_VAL

0 commit comments

Comments
 (0)