diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.h b/ydb/core/kqp/executer_actor/kqp_executer_impl.h index eb378353970d..3e10337db8f0 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(Database, Request.Transactions, Request.TxAlloc, partitionPrunerConfig, AggregationSettings, Counters, BufferActorId) { ArrayBufferMinFillPercentage = executerConfig.TableServiceConfig.GetArrayBufferMinFillPercentage(); - - if (executerConfig.TableServiceConfig.HasBufferPageAllocSize()) { - BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize(); - } + BufferPageAllocSize = executerConfig.TableServiceConfig.GetBufferPageAllocSize(); TasksGraph.GetMeta().Snapshot = IKqpGateway::TKqpSnapshot(Request.Snapshot.Step, Request.Snapshot.TxId); TasksGraph.GetMeta().RequestIsolationLevel = Request.IsolationLevel; diff --git a/ydb/core/kqp/executer_actor/kqp_planner.cpp b/ydb/core/kqp/executer_actor/kqp_planner.cpp index a25fd9df526f..4541c5dbaa7d 100644 --- a/ydb/core/kqp/executer_actor/kqp_planner.cpp +++ b/ydb/core/kqp/executer_actor/kqp_planner.cpp @@ -225,6 +225,9 @@ std::unique_ptr TKqpPlanner::SerializeReque if (ArrayBufferMinFillPercentage) { serializedTask->SetArrayBufferMinFillPercentage(*ArrayBufferMinFillPercentage); } + if (BufferPageAllocSize) { + serializedTask->SetBufferPageAllocSize(*BufferPageAllocSize); + } request.AddTasks()->Swap(serializedTask); }