diff options
author | yumkam <yumkam7@ydb.tech> | 2024-11-12 15:15:12 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-11-12 15:15:12 +0300 |
commit | 75b75e9d58fb78a90617b31ebe7489b1cfc165a0 (patch) | |
tree | a9582f22443a58fff6ee771e834a7ea533b2f185 | |
parent | edeb17d54b12a0a225e43f890a31f18208560c0c (diff) | |
download | ydb-75b75e9d58fb78a90617b31ebe7489b1cfc165a0.tar.gz |
Fix busy-wait in async compute actor (#11507)
-rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp | 2 |
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; } |