aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraneporada <aneporada@ydb.tech>2022-08-16 20:48:01 +0300
committeraneporada <aneporada@ydb.tech>2022-08-16 20:48:01 +0300
commiteea0d7f2ed8b13d2ee65cf39532df479e8862667 (patch)
tree2541efe743145b7b003ccf2b0eba103b4e30fa82
parent5a439f688d18a567ea4c9a7024cc113982cdc827 (diff)
downloadydb-eea0d7f2ed8b13d2ee65cf39532df479e8862667.tar.gz
[] Fix DqJoin type annotation for PG or NULL types
-rw-r--r--ydb/library/yql/dq/type_ann/dq_type_ann.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/dq/type_ann/dq_type_ann.cpp b/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
index f4835abdad..7d8428140c 100644
--- a/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
+++ b/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
@@ -322,7 +322,7 @@ const TStructExprType* GetDqJoinResultType(TPositionHandle pos, const TStructExp
for (const auto& it : type) {
for (const auto& it2 : it.second) {
auto memberName = FullColumnName(it.first, it2.first);
- if (makeOptional && it2.second->GetKind() != ETypeAnnotationKind::Optional) {
+ if (makeOptional && !it2.second->IsOptionalOrNull()) {
result->emplace_back(ctx.MakeType<TItemExprType>(memberName, ctx.MakeType<TOptionalExprType>(it2.second)));
} else {
result->emplace_back(ctx.MakeType<TItemExprType>(memberName, it2.second));