summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorpilik <[email protected]>2025-06-18 18:28:27 +0300
committerGitHub <[email protected]>2025-06-18 15:28:27 +0000
commit30ee2a73c863cd9287c01d25e6424b053efd886f (patch)
tree2a47af80022a389d9b8ff7228f92ab27364b543f
parent9ec785bf807dcb9678eb9663c08d051d985c42dc (diff)
[KQP] HashShuffle case bug fix (#19759)
-rw-r--r--ydb/core/kqp/query_compiler/kqp_query_compiler.cpp2
-rw-r--r--ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql2
-rw-r--r--ydb/tests/functional/tpc/data/e1/run/second_query_set/join.sql.result2
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,,
...