Skip to content

Commit 620f097

Browse files
committed
revert unneeded changes
1 parent 34305fc commit 620f097

File tree

3 files changed

+2
-6
lines changed

3 files changed

+2
-6
lines changed

ydb/library/yql/dq/runtime/dq_input_impl.h

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,6 @@
33
#include <yql/essentials/core/yql_expr_type_annotation.h>
44
#include <yql/essentials/minikql/computation/mkql_computation_node_holders.h>
55
#include <yql/essentials/minikql/mkql_node.h>
6-
#include <ydb/library/actors/core/log.h>
7-
#include <util/stream/output.h>
8-
#include <util/string/join.h>
96

107
namespace NYql::NDq {
118

ydb/library/yql/dq/runtime/ya.make

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ LIBRARY()
22

33
PEERDIR(
44
contrib/libs/apache/arrow
5-
ydb/library/actors/core
65
ydb/library/actors/util
76
ydb/library/formats/arrow
87
ydb/library/formats/arrow/hash

ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -674,11 +674,11 @@ class TTaskRunnerActor
674674
auto cookie = ev->Cookie;
675675
auto inputMap = ev->Get()->AskFreeSpace
676676
? Inputs
677-
: std::move(ev->Get()->InputChannels);
677+
: ev->Get()->InputChannels;
678678

679679
auto sourcesMap = Sources;
680680

681-
Invoker->Invoke([selfId, cookie, actorSystem, replyTo, taskRunner=TaskRunner, inputMap=std::move(inputMap), sourcesMap=std::move(sourcesMap), memLimit=ev->Get()->MemLimit, settings=Settings, stageId=StageId, runtimeData=RuntimeData]() mutable {
681+
Invoker->Invoke([selfId, cookie, actorSystem, replyTo, taskRunner=TaskRunner, inputMap, sourcesMap, memLimit=ev->Get()->MemLimit, settings=Settings, stageId=StageId, runtimeData=RuntimeData]() mutable {
682682
try {
683683
// auto guard = taskRunner->BindAllocator(); // only for local mode
684684
// guard.GetMutex()->SetLimit(memLimit);

0 commit comments

Comments
 (0)