Skip to content

Commit bb85104

Browse files
committed
Fix tests
1 parent 2f71038 commit bb85104

File tree

2 files changed

+6
-10
lines changed

2 files changed

+6
-10
lines changed

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
@@ -2486,7 +2486,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
24862486
UNIT_ASSERT_C(result.GetStatus() == NYdb::EStatus::SUCCESS, result.GetIssues().ToString());
24872487

24882488
auto client = kikimr.GetQueryClient();
2489-
{
2489+
{
24902490
auto prepareResult = client.ExecuteQuery(R"(
24912491
REPLACE INTO `/Root/ColumnShard` (a, b, c) VALUES
24922492
(1u, 1, 5),
@@ -2516,15 +2516,15 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
25162516
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (NarrowMap (WideFromBlocks"), plan.QueryStats->Getquery_ast());
25172517
break;
25182518
case NKikimrConfig::TTableServiceConfig_EBlockChannelsMode_BLOCK_CHANNELS_AUTO:
2519-
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (ExpandMap (NarrowMap (WideFromBlocks"), plan.QueryStats->Getquery_ast());
2519+
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (WideFromBlocks"), plan.QueryStats->Getquery_ast());
25202520
break;
25212521
case NKikimrConfig::TTableServiceConfig_EBlockChannelsMode_BLOCK_CHANNELS_FORCE:
25222522
UNIT_ASSERT_C(plan.QueryStats->Getquery_ast().Contains("return (FromFlow (WideMap"), plan.QueryStats->Getquery_ast());
25232523
break;
25242524
}
25252525
}
25262526

2527-
{
2527+
{
25282528
auto it = client.StreamExecuteQuery(R"(
25292529
SELECT
25302530
b, COUNT(*), SUM(a)

0 commit comments

Comments
 (0)