Fix busy-wait in async compute actor (backport #11507) (#11527)

yumkam · web-flow · commit 0bf2b3802d2a · 2024-11-13T11:41:28.000+03:00
diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp
@@ -440,7 +440,7 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC
         if (!shouldSkipData && !outputChannel.EarlyFinish && !hasFreeMemory) {
             CA_LOG_T("DrainOutputChannel return because No free memory in channel, channel: " << outputChannel.ChannelId);
             ProcessOutputsState.HasDataToSend |= !outputChannel.Finished;
-            ProcessOutputsState.AllOutputsFinished = !outputChannel.Finished;
+            ProcessOutputsState.AllOutputsFinished &= outputChannel.Finished;
             return;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -440,7 +440,7 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC`
`440`	`440`	`if (!shouldSkipData && !outputChannel.EarlyFinish && !hasFreeMemory) {`
`441`	`441`	`CA_LOG_T("DrainOutputChannel return because No free memory in channel, channel: " << outputChannel.ChannelId);`
`442`	`442`	`ProcessOutputsState.HasDataToSend \|= !outputChannel.Finished;`
`443`		`- ProcessOutputsState.AllOutputsFinished = !outputChannel.Finished;`
	`443`	`+ ProcessOutputsState.AllOutputsFinished &= outputChannel.Finished;`
`444`	`444`	`return;`
`445`	`445`	`}`
`446`	`446`