[KQP] Some fixes

pashandor789 · pashandor789 · commit 64709e8c99fe · 2025-03-04T09:14:02.000Z
diff --git a/ydb/core/kqp/compute_actor/kqp_compute_actor_factory.cpp b/ydb/core/kqp/compute_actor/kqp_compute_actor_factory.cpp
@@ -140,7 +140,7 @@ class TKqpCaFactory : public IKqpNodeComputeActorFactory {
                 inputChannelsCount += i.ChannelsSize();
             }
 
-            memoryLimits.ChannelBufferSize = std::max<ui32>(estimation.ChannelBufferMemoryLimit / std::max<ui32>(1, inputChannelsCount), MinChannelBufferSize.load());
+            memoryLimits.ChannelBufferSize = 10 * 1024 * 1024;
             memoryLimits.OutputChunkMaxSize = args.OutputChunkMaxSize;
             AFL_DEBUG(NKikimrServices::KQP_COMPUTE)("event", "channel_info")
                 ("ch_size", estimation.ChannelBufferMemoryLimit)

Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ class TKqpCaFactory : public IKqpNodeComputeActorFactory {`
`140`	`140`	`inputChannelsCount += i.ChannelsSize();`
`141`	`141`	`}`
`142`	`142`
`143`		`- memoryLimits.ChannelBufferSize = std::max<ui32>(estimation.ChannelBufferMemoryLimit / std::max<ui32>(1, inputChannelsCount), MinChannelBufferSize.load());`
	`143`	`+ memoryLimits.ChannelBufferSize = 10 * 1024 * 1024;`
`144`	`144`	`memoryLimits.OutputChunkMaxSize = args.OutputChunkMaxSize;`
`145`	`145`	`AFL_DEBUG(NKikimrServices::KQP_COMPUTE)("event", "channel_info")`
`146`	`146`	`("ch_size", estimation.ChannelBufferMemoryLimit)`