diff --git a/ydb/core/kqp/runtime/kqp_write_actor.cpp b/ydb/core/kqp/runtime/kqp_write_actor.cpp index b21dc6e2e8ad..ec965c4db2d6 100644 --- a/ydb/core/kqp/runtime/kqp_write_actor.cpp +++ b/ydb/core/kqp/runtime/kqp_write_actor.cpp @@ -1294,7 +1294,7 @@ class TKqpDirectWriteActor : public TActorBootstrapped, pu void Process() { if (GetFreeSpace() <= 0) { WaitingForTableActor = true; - } else if (WaitingForTableActor && GetFreeSpace() > MessageSettings.InFlightMemoryLimitPerActorBytes / 2) { + } else if (WaitingForTableActor) { ResumeExecution(); }