Skip to content

Commit 6111922

Browse files
committed
fixup
1 parent 69259bd commit 6111922

File tree

3 files changed

+0
-6
lines changed

3 files changed

+0
-6
lines changed

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ class TSpillingTransformProvider {
1616

1717
TSpillingTransformProvider(const TSpillingSettings& spillingSettings): SpillingSettings(spillingSettings){};
1818

19-
2019
TCallableVisitFunc operator()(TInternName name) {
2120
if (RuntimeVersion >= 50U && SpillingSettings.EnableSpillingInGraceJoin && (name == "GraceJoin" || name == "GraceSelfJoin")) {
2221
return [name](NKikimr::NMiniKQL::TCallable& callable, const TTypeEnvironment& env) {
@@ -29,7 +28,6 @@ class TSpillingTransformProvider {
2928
return TRuntimeNode(callableBuilder.Build(), false);
3029
};
3130
}
32-
3331

3432
return TCallableVisitFunc();
3533
}

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

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

1178-
std::cerr << "MISHA " << callable.GetType()->GetName() << std::endl;
1179-
11801178
return WrapGraceJoinCommon(callable, ctx, false, isSpillingAllowed);
11811179
}
11821180

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

Lines changed: 0 additions & 2 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>
@@ -677,7 +676,6 @@ namespace NYql::NDqs {
677676
Y_ABORT_UNLESS(false);
678677
}
679678
*/
680-
681679
TSpillingSettings spillingSettings{Settings->IsSpillingInGraceJoinEnabled()};
682680
StagePrograms[stageInfo.first] = std::make_tuple(
683681
NDq::BuildProgram(

0 commit comments

Comments
 (0)