Skip to content

Commit b250ff7

Browse files
committed
[KQP] HashShuffle case bug fix
1 parent 7137cf8 commit b250ff7

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

ydb/core/kqp/query_compiler/kqp_query_compiler.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1333,6 +1333,7 @@ class TKqpQueryCompiler : public IKqpQueryCompiler {
13331333
using enum NDq::EHashShuffleFuncType;
13341334
case HashV1: {
13351335
shuffleProto.MutableHashV1();
1336+
break;
13361337
}
13371338
case ColumnShardHashV1: {
13381339
auto& columnHashV1 = *shuffleProto.MutableColumnShardHashV1();
@@ -1370,6 +1371,7 @@ class TKqpQueryCompiler : public IKqpQueryCompiler {
13701371
auto typeId = GetDataTypeInfo(slot).TypeId;
13711372
columnHashV1.AddKeyColumnTypes(typeId);
13721373
}
1374+
break;
13731375
}
13741376
};
13751377

0 commit comments

Comments
 (0)