Skip to content

Commit d776d5c

Browse files
authored
[Backport stable-25-3-1] Use default value of BufferPageAllocSize from proto (#28310)
2 parents 0aec86a + 234fea6 commit d776d5c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,10 +156,7 @@ class TKqpExecuterBase : public TActor<TDerived> {
156156
, TasksGraph(Request.TxAlloc, partitionPrunerConfig, AggregationSettings, Counters, BufferActorId)
157157
{
158158
ArrayBufferMinFillPercentage = executerConfig.TableServiceConfig.GetArrayBufferMinFillPercentage();
159-
160-
if (executerConfig.TableServiceConfig.HasBufferPageAllocSize()) {
161-
BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize();
162-
}
159+
BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize();
163160

164161
EnableReadsMerge = *MergeDatashardReadsControl() == 1;
165162
TasksGraph.GetMeta().Snapshot = IKqpGateway::TKqpSnapshot(Request.Snapshot.Step, Request.Snapshot.TxId);

ydb/core/kqp/executer_actor/kqp_planner.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,9 @@ std::unique_ptr<TEvKqpNode::TEvStartKqpTasksRequest> TKqpPlanner::SerializeReque
224224
if (ArrayBufferMinFillPercentage) {
225225
serializedTask->SetArrayBufferMinFillPercentage(*ArrayBufferMinFillPercentage);
226226
}
227+
if (BufferPageAllocSize) {
228+
serializedTask->SetBufferPageAllocSize(*BufferPageAllocSize);
229+
}
227230
request.AddTasks()->Swap(serializedTask);
228231
}
229232

0 commit comments

Comments
 (0)