Skip to content

Commit e39ac01

Browse files
committed
[KQP] Some fixes
1 parent 345254b commit e39ac01

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/kqp/compute_actor/kqp_compute_actor_factory.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,8 +140,8 @@ class TKqpCaFactory : public IKqpNodeComputeActorFactory {
140140
inputChannelsCount += i.ChannelsSize();
141141
}
142142

143-
memoryLimits.ChannelBufferSize = std::numeric_limits<ui64>::max();
144-
// memoryLimits.ChannelBufferSize = std::max<ui32>(estimation.ChannelBufferMemoryLimit / std::max<ui32>(1, inputChannelsCount), MinChannelBufferSize.load());
143+
memoryLimits.ChannelBufferSize = std::max<ui32>(estimation.ChannelBufferMemoryLimit / std::max<ui32>(1, inputChannelsCount), MinChannelBufferSize.load());
144+
memoryLimits.ChannelBufferSize *= 5;
145145
memoryLimits.OutputChunkMaxSize = args.OutputChunkMaxSize;
146146
AFL_DEBUG(NKikimrServices::KQP_COMPUTE)("event", "channel_info")
147147
("ch_size", estimation.ChannelBufferMemoryLimit)

0 commit comments

Comments
 (0)