Skip to content

Commit 9c09778

Browse files
committed
fixup
1 parent 9c8982c commit 9c09778

File tree

3 files changed

+4
-7
lines changed

3 files changed

+4
-7
lines changed

ydb/library/yql/minikql/comp_nodes/mkql_factory.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -234,8 +234,8 @@ struct TCallableComputationNodeBuilderFuncMapFiller {
234234
{"JoinDict", &WrapJoinDict},
235235
{"GraceJoin", &WrapGraceJoin},
236236
{"GraceSelfJoin", &WrapGraceSelfJoin},
237-
{"GraceJoinWithSpilling", &WrapGraceJoinWithSpilling},
238-
{"GraceSelfJoinWithSpilling", &WrapGraceSelfJoinWithSpilling},
237+
{"GraceJoinWithSpilling", &WrapGraceJoin},
238+
{"GraceSelfJoinWithSpilling", &WrapGraceSelfJoin},
239239
{"MapJoinCore", &WrapMapJoinCore},
240240
{"CommonJoinCore", &WrapCommonJoinCore},
241241
{"CombineCore", &WrapCombineCore},

ydb/library/yql/minikql/comp_nodes/mkql_grace_join.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1171,7 +1171,7 @@ IComputationNode* WrapGraceJoinCommon(TCallable& callable, const TComputationNod
11711171
IComputationNode* WrapGraceJoin(TCallable& callable, const TComputationNodeFactoryContext& ctx) {
11721172
MKQL_ENSURE(callable.GetInputsCount() == 8, "Expected 8 args");
11731173
bool isSpillingAllowed = false;
1174-
if (callable.GetType()->GetName() == "GraceJoinCoreWithSpilling") {
1174+
if (callable.GetType()->GetName() == "GraceJoinWithSpilling") {
11751175
isSpillingAllowed = true;
11761176
}
11771177

@@ -1182,7 +1182,7 @@ IComputationNode* WrapGraceSelfJoin(TCallable& callable, const TComputationNodeF
11821182
MKQL_ENSURE(callable.GetInputsCount() == 7, "Expected 7 args");
11831183

11841184
bool isSpillingAllowed = false;
1185-
if (callable.GetType()->GetName() == "GraceSelfJoinCoreWithSpilling") {
1185+
if (callable.GetType()->GetName() == "GraceSelfJoinWithSpilling") {
11861186
isSpillingAllowed = true;
11871187
}
11881188

ydb/library/yql/providers/dq/planner/execution_planner.cpp

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
#include "execution_planner.h"
22

33
#include <ydb/library/yql/dq/integration/yql_dq_integration.h>
4-
#include <ydb/library/yql/minikql/mkql_runtime_version.h>
54
#include <ydb/library/yql/providers/dq/expr_nodes/dqs_expr_nodes.h>
65
#include <ydb/library/yql/providers/dq/opt/dqs_opt.h>
76
#include <ydb/library/yql/providers/dq/opt/logical_optimize.h>
@@ -29,8 +28,6 @@
2928
#include <ydb/library/yql/minikql/mkql_node_serialization.h>
3029
#include <ydb/library/actors/core/event_pb.h>
3130

32-
#include <util/generic/xrange.h>
33-
3431
#include <stack>
3532

3633
using namespace NYql;

0 commit comments

Comments
 (0)