YQ-4043 fixed hanging in kqp write actor (#14017)

GrigoriyPA · stanislav-shchetinin · commit b14cff499a3d · 2025-01-30T15:06:45.000+03:00
diff --git 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<TKqpDirectWriteActor>, pu
     void Process() {
         if (GetFreeSpace() <= 0) {
             WaitingForTableActor = true;
-        } else if (WaitingForTableActor && GetFreeSpace() > MessageSettings.InFlightMemoryLimitPerActorBytes / 2) {
+        } else if (WaitingForTableActor) {
             ResumeExecution();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -1294,7 +1294,7 @@ class TKqpDirectWriteActor : public TActorBootstrapped<TKqpDirectWriteActor>, pu`
`1294`	`1294`	`void Process() {`
`1295`	`1295`	`if (GetFreeSpace() <= 0) {`
`1296`	`1296`	`WaitingForTableActor = true;`
`1297`		`- } else if (WaitingForTableActor && GetFreeSpace() > MessageSettings.InFlightMemoryLimitPerActorBytes / 2) {`
	`1297`	`+ } else if (WaitingForTableActor) {`
`1298`	`1298`	`ResumeExecution();`
`1299`	`1299`	`}`
`1300`	`1300`