From b6c22b8e4dcbeb381f1a0637a0a2eee4bdcd3d1a Mon Sep 17 00:00:00 2001 From: Ivan Lezhankin Date: Wed, 5 Nov 2025 13:10:42 +0300 Subject: [PATCH 1/2] Use default value of BufferPageAllocSize from proto --- ydb/core/kqp/executer_actor/kqp_executer_impl.h | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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; From 80286e3310b494ec3d98ded9b5335e1d60715555 Mon Sep 17 00:00:00 2001 From: Ivan Lezhankin Date: Thu, 6 Nov 2025 14:13:55 +0300 Subject: [PATCH 2/2] Push value to serialized tasks also --- ydb/core/kqp/executer_actor/kqp_planner.cpp | 3 +++ 1 file changed, 3 insertions(+) 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); }