aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPavel Velikhov <pavelvelikhov@ydb.tech>2024-04-09 13:24:11 +0300
committerGitHub <noreply@github.com>2024-04-09 13:24:11 +0300
commit34e4a37cbe98992bea2f024ffd6f97ea59e8eceb (patch)
tree18983a6a5e228568e82eaefe19c3ad5fdde6f391
parente657d58d45008d0ef7e8aa36ef65e6f9c6cebf2d (diff)
downloadydb-34e4a37cbe98992bea2f024ffd6f97ea59e8eceb.tar.gz
Fixed multiple inputs to aggeregate in Simplified JSON (#3566)
-rw-r--r--ydb/core/kqp/opt/kqp_query_plan.cpp7
1 files changed, 1 insertions, 6 deletions
diff --git a/ydb/core/kqp/opt/kqp_query_plan.cpp b/ydb/core/kqp/opt/kqp_query_plan.cpp
index 31d07480116..1ef5e5f60ab 100644
--- a/ydb/core/kqp/opt/kqp_query_plan.cpp
+++ b/ydb/core/kqp/opt/kqp_query_plan.cpp
@@ -2057,7 +2057,7 @@ NJson::TJsonValue ReconstructQueryPlanRec(const NJson::TJsonValue& plan,
}
// Sometimes we have multiple inputs for these operators, break after the first one
- if (opName == "Filter" || opName == "TopSort") {
+ if (opName == "Filter" || opName == "TopSort" || opName == "Aggregate") {
break;
}
}
@@ -2226,11 +2226,6 @@ TString AddSimplifiedPlan(const TString& planText, bool analyzeMode) {
planJson["SimplifiedPlan"] = SimplifyQueryPlan(planCopy.GetMapSafe().at("Plan"));
- // Don't print the OLAP plan yet, there are some non UTF-8 symbols there that need to be fixed
- //TTempBufOutput stringStream;
- //NYdb::NConsoleClient::TQueryPlanPrinter printer(NYdb::NConsoleClient::EOutputFormat::PrettyTable, analyzeMode, stringStream);
- //printer.Print(planJson.GetStringRobust());
- //planJson["OLAPText"] = stringStream.Data();
return planJson.GetStringRobust();
}