diff options
| author | mrlolthe1st <[email protected]> | 2023-09-29 14:05:49 +0300 |
|---|---|---|
| committer | mrlolthe1st <[email protected]> | 2023-09-29 14:39:01 +0300 |
| commit | ff60d0edb1fffa224b9e1080f09dbd49e4326131 (patch) | |
| tree | 7ffd4f3ac1a96aad4e10db3e9abba7bb667ee6e1 | |
| parent | df08b17674738bb2e67191b1f88c3729d1f86083 (diff) | |
revert rXXXXXX in trunk
Revert "YQL-15717: Fix FullResultsWriter"
This reverts commit c0aa95d5c9b8981d2ef95cc8abdde1c979c30732, reversing
changes made to df2ea4c48ed8b53f787d48abf09b3161c685433e.
| -rw-r--r-- | ydb/library/yql/providers/dq/actors/result_actor_base.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/dq/actors/result_actor_base.h b/ydb/library/yql/providers/dq/actors/result_actor_base.h index 0a23fa5824c..684631417c4 100644 --- a/ydb/library/yql/providers/dq/actors/result_actor_base.h +++ b/ydb/library/yql/providers/dq/actors/result_actor_base.h @@ -230,10 +230,10 @@ namespace NYql::NDqs::NExecutionHelpers { YQL_LOG_CTX_ROOT_SESSION_SCOPE(TraceId); YQL_CLOG(DEBUG, ProviderDq) << __FUNCTION__; Y_VERIFY(ev->Get()->Record.GetMessageId() == WriteQueue.front().MessageId); - while (!WriteQueue.empty() && !WriteQueue.front().SentProcessedEvent) { // messages, received before limits exceeded, are already been reported + if (!WriteQueue.front().SentProcessedEvent) { // messages, received before limits exceeded, are already been reported TBase::Send(TBase::SelfId(), MakeHolder<TEvMessageProcessed>(WriteQueue.front().MessageId)); - WriteQueue.pop(); } + WriteQueue.pop(); if (WriteQueue.empty()) { WaitingAckFromFRW = false; |