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

yumkam · web-flow · commit 75b75e9d58fb · 2024-11-12T15:15:12.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
@@ -441,7 +441,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
`@@ -441,7 +441,7 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC`
`441`	`441`	`if (!shouldSkipData && !outputChannel.EarlyFinish && !hasFreeMemory) {`
`442`	`442`	`CA_LOG_T("DrainOutputChannel return because No free memory in channel, channel: " << outputChannel.ChannelId);`
`443`	`443`	`ProcessOutputsState.HasDataToSend \|= !outputChannel.Finished;`
`444`		`- ProcessOutputsState.AllOutputsFinished = !outputChannel.Finished;`
	`444`	`+ ProcessOutputsState.AllOutputsFinished &= outputChannel.Finished;`
`445`	`445`	`return;`
`446`	`446`	`}`
`447`	`447`