Skip to content

Commit 00f3749

Browse files
abhashjainNikhilCollooru
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 2535ff4 commit 00f3749

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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)