aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoryumkam <yumkam7@ydb.tech>2024-11-12 15:15:12 +0300
committerGitHub <noreply@github.com>2024-11-12 15:15:12 +0300
commit75b75e9d58fb78a90617b31ebe7489b1cfc165a0 (patch)
treea9582f22443a58fff6ee771e834a7ea533b2f185
parentedeb17d54b12a0a225e43f890a31f18208560c0c (diff)
downloadydb-75b75e9d58fb78a90617b31ebe7489b1cfc165a0.tar.gz
Fix busy-wait in async compute actor (#11507)
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp2
1 files changed, 1 insertions, 1 deletions
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
index dac377c889..da69681862 100644
--- 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 @@ private:
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;
}