Skip to content

Commit ec69909

Browse files
abhashjainPresto CUDF CI
authored andcommitted
[presto] Fixing the Writer count from the system config (prestodb#25941)
Summary: In this diff I update the taskWriterCount and taskPartitionedWriterCount value to system config which was deleted in D80124169 diff. kTaskWriterCount is important config for the Impulse connector created table to increase the parallism to ingestion the data by creating multiple writer drivers. Differential Revision: D81522582
1 parent d32b56e commit ec69909

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

presto-native-execution/presto_cpp/main/PrestoToVeloxQueryConfig.cpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,12 @@ void updateFromSystemConfigs(
139139
{std::string(SystemConfig::kUseLegacyArrayAgg),
140140
velox::core::QueryConfig::kPrestoArrayAggIgnoreNulls},
141141

142+
{std::string{SystemConfig::kTaskWriterCount},
143+
velox::core::QueryConfig::kTaskWriterCount},
144+
145+
{std::string{SystemConfig::kTaskPartitionedWriterCount},
146+
velox::core::QueryConfig::kTaskPartitionedWriterCount},
147+
142148
{std::string(SystemConfig::kSinkMaxBufferSize),
143149
velox::core::QueryConfig::kMaxOutputBufferSize,
144150
[](const auto& value) {

0 commit comments

Comments
 (0)