Skip to content

Commit 9ea9e0f

Browse files
committed
[KIKIMR-21472] Output the final AST in explain query (ydb-platform#6487)
(cherry picked from commit 85d4495)
1 parent ac22cb5 commit 9ea9e0f

File tree

3 files changed

+7
-11
lines changed

3 files changed

+7
-11
lines changed

ydb/core/kqp/host/kqp_explain_prepared.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ class TKqpExplainPreparedTransformer : public NYql::TGraphTransformerBase {
6666

6767
PhyQuerySetTxPlans(query, TKqpPhysicalQuery(TransformCtx->ExplainTransformerInput), std::move(TxResults),
6868
ctx, Cluster, TransformCtx->Tables, TransformCtx->Config, TypeCtx, OptimizeCtx);
69-
query.SetQueryAst(KqpExprToPrettyString(*TransformCtx->ExplainTransformerInput, ctx));
69+
query.SetQueryAst(KqpExprToPrettyString(*input, ctx));
7070

7171
TransformCtx->ExplainTransformerInput = nullptr;
7272
return TStatus::Ok;

ydb/core/kqp/ut/olap/helpers/aggregation.h

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -81,12 +81,7 @@ class TAggregationTestCase {
8181
bool UseLlvm = true;
8282
public:
8383
void FillExpectedAggregationGroupByPlanOptions() {
84-
#if SSA_RUNTIME_VERSION >= 2U
85-
// AddExpectedPlanOptions("TKqpOlapAgg");
8684
AddExpectedPlanOptions("WideCombiner");
87-
#else
88-
AddExpectedPlanOptions("CombineCore");
89-
#endif
9085
}
9186
TString GetFixedQuery() const {
9287
TStringBuilder queryFixed;
@@ -177,7 +172,8 @@ void CheckPlanForAggregatePushdown(
177172
const TString& query,
178173
TClient& client,
179174
const std::vector<std::string>& expectedPlanNodes,
180-
const std::string& readNodeType) {
175+
const std::string& readNodeType)
176+
{
181177
auto res = StreamExplainQuery(query, client);
182178
UNIT_ASSERT_C(res.IsSuccess(), res.GetIssues().ToString());
183179

@@ -242,4 +238,4 @@ void WriteTestDataForTableWithNulls(TKikimrRunner& kikimr, TString testTable);
242238

243239
void TestTableWithNulls(const std::vector<TAggregationTestCase>& cases, const bool genericQuery = false);
244240

245-
}
241+
}

ydb/core/kqp/ut/olap/kqp_olap_ut.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2515,7 +2515,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
25152515
UNIT_ASSERT_C(result.GetStatus() == NYdb::EStatus::SUCCESS, result.GetIssues().ToString());
25162516

25172517
auto client = kikimr.GetQueryClient();
2518-
{
2518+
{
25192519
auto prepareResult = client.ExecuteQuery(R"(
25202520
REPLACE INTO `/Root/ColumnShard` (a, b, c) VALUES
25212521
(1u, 1, 5),
@@ -2545,15 +2545,15 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
25452545
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (NarrowMap (WideFromBlocks"), plan.QueryStats->Getquery_ast());
25462546
break;
25472547
case NKikimrConfig::TTableServiceConfig_EBlockChannelsMode_BLOCK_CHANNELS_AUTO:
2548-
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (ExpandMap (NarrowMap (WideFromBlocks"), plan.QueryStats->Getquery_ast());
2548+
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (WideFromBlocks"), plan.QueryStats->Getquery_ast());
25492549
break;
25502550
case NKikimrConfig::TTableServiceConfig_EBlockChannelsMode_BLOCK_CHANNELS_FORCE:
25512551
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (WideMap"), plan.QueryStats->Getquery_ast());
25522552
break;
25532553
}
25542554
}
25552555

2556-
{
2556+
{
25572557
auto it = client.StreamExecuteQuery(R"(
25582558
SELECT
25592559
b, COUNT(*), SUM(a)

0 commit comments

Comments
 (0)