diff options
author | whcrc <whcrc@yandex-team.ru> | 2022-03-10 22:25:38 +0300 |
---|---|---|
committer | whcrc <whcrc@yandex-team.ru> | 2022-03-10 22:25:38 +0300 |
commit | 8a761ab3a703bf5bdc4c0238262df469a9f96d88 (patch) | |
tree | cd69eb28d07a76c9a118310000d696a6d901c989 | |
parent | b0240a1c2bf6cc189af6aaec797dc6a8f49d8274 (diff) | |
download | ydb-8a761ab3a703bf5bdc4c0238262df469a9f96d88.tar.gz |
YQL-14362: fix bug in task_runner_actor_local
ref:d1d343a6db5360ac345fafb2eecac1e03c1a9550
-rw-r--r-- | ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp b/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp index a7a3618c51..c5dfa28b38 100644 --- a/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp +++ b/ydb/library/yql/dq/actors/task_runner/task_runner_actor_local.cpp @@ -170,7 +170,7 @@ private: TVector<NDqProto::TData> chunks; for (;maxChunks && remain > 0 && !isFinished && hasData; maxChunks--, remain -= dataSize) { NDqProto::TData data; - auto hasData = channel->Pop(data, remain); + hasData = channel->Pop(data, remain); dataSize = data.GetRaw().size(); isFinished = !hasData && channel->IsFinished(); |