summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraidarsamer <[email protected]>2023-04-20 08:19:37 +0300
committeraidarsamer <[email protected]>2023-04-20 08:19:37 +0300
commit7a3c705e4b1d327ffc2ece5f7671aed473313022 (patch)
tree8d98a59048497de3c257681af44250a8734127c3
parent2c3286006a1757dc43c09a72baf89ad5d18daf30 (diff)
Add pragma OptUseFinalizeByKey to use WideCombiner in test.
-rw-r--r--ydb/core/kqp/ut/olap/kqp_olap_ut.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp b/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp
index b84fd91dfa5..8be0b7c0941 100644
--- a/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp
+++ b/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp
@@ -1624,8 +1624,6 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
Y_UNIT_TEST(AggregationCountGroupByPushdown) {
- // Should be fixed in KIKIMR-17007
- return;
auto settings = TKikimrSettings()
.SetWithSampleTables(false)
.SetEnableOlapSchemaOperations(true);
@@ -1648,6 +1646,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
{
TString query = R"(
--!syntax_v1
+ PRAGMA Kikimr.OptUseFinalizeByKey;
SELECT
level, COUNT(level)
FROM `/Root/olapStore/olapTable`
@@ -1663,7 +1662,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
// Check plan
#if SSA_RUNTIME_VERSION >= 2U
- CheckPlanForAggregatePushdown(query, tableClient, { "WideCombiner" }, "TableFullScan");
+ CheckPlanForAggregatePushdown(query, tableClient, { "WideCombiner" }, "Aggregate-TableFullScan");
// CheckPlanForAggregatePushdown(query, tableClient, { "TKqpOlapAgg" }, "TableFullScan");
#else
CheckPlanForAggregatePushdown(query, tableClient, { "CombineCore" }, "");