diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.h b/ydb/core/kqp/executer_actor/kqp_executer_impl.h index 24557a0ad219..d9de25af0e91 100644 --- a/ydb/core/kqp/executer_actor/kqp_executer_impl.h +++ b/ydb/core/kqp/executer_actor/kqp_executer_impl.h @@ -156,10 +156,7 @@ class TKqpExecuterBase : public TActor { , TasksGraph(Request.TxAlloc, partitionPrunerConfig, AggregationSettings, Counters, BufferActorId) { ArrayBufferMinFillPercentage = executerConfig.TableServiceConfig.GetArrayBufferMinFillPercentage(); - - if (executerConfig.TableServiceConfig.HasBufferPageAllocSize()) { - BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize(); - } + BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize(); EnableReadsMerge = *MergeDatashardReadsControl() == 1; TasksGraph.GetMeta().Snapshot = IKqpGateway::TKqpSnapshot(Request.Snapshot.Step, Request.Snapshot.TxId); diff --git a/ydb/core/kqp/executer_actor/kqp_planner.cpp b/ydb/core/kqp/executer_actor/kqp_planner.cpp index c63e1f0c8dfd..73d9a245a939 100644 --- a/ydb/core/kqp/executer_actor/kqp_planner.cpp +++ b/ydb/core/kqp/executer_actor/kqp_planner.cpp @@ -224,6 +224,9 @@ std::unique_ptr TKqpPlanner::SerializeReque if (ArrayBufferMinFillPercentage) { serializedTask->SetArrayBufferMinFillPercentage(*ArrayBufferMinFillPercentage); } + if (BufferPageAllocSize) { + serializedTask->SetBufferPageAllocSize(*BufferPageAllocSize); + } request.AddTasks()->Swap(serializedTask); }