Skip to content

Commit 2e3c67e

Browse files
authored
[KQP] Shuffle Elimination NULL value processing added in runtime (#15779)
1 parent 2e01cde commit 2e3c67e

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ydb/library/yql/dq/runtime/dq_output_consumer.cpp

+4
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,10 @@ struct TColumnShardHashV1 {
124124

125125
template <typename TValue>
126126
void Update(const TValue& uv, size_t keyIdx) {
127+
if (!uv.HasValue()) {
128+
return;
129+
}
130+
127131
switch (KeyColumnTypes[keyIdx]) {
128132
case NYql::NProto::Bool: {
129133
auto value = uv.template Get<bool>();

0 commit comments

Comments
 (0)