aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorwhcrc <whcrc@yandex-team.ru>2022-03-10 22:25:38 +0300
committerwhcrc <whcrc@yandex-team.ru>2022-03-10 22:25:38 +0300
commit8a761ab3a703bf5bdc4c0238262df469a9f96d88 (patch)
treecd69eb28d07a76c9a118310000d696a6d901c989
parentb0240a1c2bf6cc189af6aaec797dc6a8f49d8274 (diff)
downloadydb-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.cpp2
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();