diff options
author | aneporada <aneporada@ydb.tech> | 2022-08-16 20:48:01 +0300 |
---|---|---|
committer | aneporada <aneporada@ydb.tech> | 2022-08-16 20:48:01 +0300 |
commit | eea0d7f2ed8b13d2ee65cf39532df479e8862667 (patch) | |
tree | 2541efe743145b7b003ccf2b0eba103b4e30fa82 | |
parent | 5a439f688d18a567ea4c9a7024cc113982cdc827 (diff) | |
download | ydb-eea0d7f2ed8b13d2ee65cf39532df479e8862667.tar.gz |
[] Fix DqJoin type annotation for PG or NULL types
-rw-r--r-- | ydb/library/yql/dq/type_ann/dq_type_ann.cpp | 2 |
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)); |