From 30ee2a73c863cd9287c01d25e6424b053efd886f Mon Sep 17 00:00:00 2001 From: pilik Date: Wed, 18 Jun 2025 18:28:27 +0300 Subject: [KQP] HashShuffle case bug fix (#19759) --- ydb/core/kqp/query_compiler/kqp_query_compiler.cpp | 2 ++ ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql | 2 +- ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result | 2 +- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/ydb/core/kqp/query_compiler/kqp_query_compiler.cpp b/ydb/core/kqp/query_compiler/kqp_query_compiler.cpp index f15e1be088c..ce81b7a2166 100644 --- a/ydb/core/kqp/query_compiler/kqp_query_compiler.cpp +++ b/ydb/core/kqp/query_compiler/kqp_query_compiler.cpp @@ -1390,6 +1390,7 @@ private: using enum NDq::EHashShuffleFuncType; case HashV1: { shuffleProto.MutableHashV1(); + break; } case ColumnShardHashV1: { auto& columnHashV1 = *shuffleProto.MutableColumnShardHashV1(); @@ -1427,6 +1428,7 @@ private: auto typeId = GetDataTypeInfo(slot).TypeId; columnHashV1.AddKeyColumnTypes(typeId); } + break; } }; diff --git a/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql b/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql index 258759cff81..23d87dc48a9 100644 --- a/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql +++ b/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql @@ -8,4 +8,4 @@ SELECT test_table_2.data_4 AS data_4 FROM test_table_1 FULL JOIN test_table_2 ON test_table_1.key_1 = test_table_2.key_4 -ORDER BY data_1 LIMIT 10; \ No newline at end of file +ORDER BY key, key_2, key_3, data_1, data_2, data_3, data_4 LIMIT 10; \ No newline at end of file diff --git a/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result b/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result index ce2d590ab5c..9dc588b8177 100644 --- a/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result +++ b/ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result @@ -1,5 +1,5 @@ key,key_2,key_3,data_1,data_2,data_3,data_4 -,,2,,,10,13 ,,1,,,8,12 +,,2,,,10,13 "val1",1,,"string",2,, ... -- cgit v1.3