Skip to content

Commit 870b68e

Browse files
committed
renaming works
1 parent 9c09778 commit 870b68e

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

ydb/library/yql/dq/tasks/dq_task_program.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ using namespace NYql::NNodes;
1616
class TSpillingTransformProvider {
1717
public:
1818
TCallableVisitFunc operator()(TInternName name) {
19-
if (name == "GraceJoinCore" || name == "GraceSelfJoinCore") {
19+
if (name == "GraceJoin" || name == "GraceSelfJoin") {
2020
return [name](NKikimr::NMiniKQL::TCallable& callable, const TTypeEnvironment& env) {
2121
TCallableBuilder callableBuilder(env,
2222
TStringBuilder() << callable.GetType()->GetName() << "WithSpilling",

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1175,6 +1175,8 @@ IComputationNode* WrapGraceJoin(TCallable& callable, const TComputationNodeFacto
11751175
isSpillingAllowed = true;
11761176
}
11771177

1178+
std::cerr << "MISHA " << callable.GetType()->GetName() << std::endl;
1179+
11781180
return WrapGraceJoinCommon(callable, ctx, false, isSpillingAllowed);
11791181
}
11801182

0 commit comments

Comments
 (0)