aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraneporada <aneporada@ydb.tech>2023-12-06 12:01:29 +0300
committeraneporada <aneporada@ydb.tech>2023-12-06 12:38:36 +0300
commite83c481c67c6d22053de832f656e049faeab0f80 (patch)
tree55c60b34219880872b1f6c587055f9a0a6c1e64e
parentbbdd76a9666c19dd2eb27a842909358e8b541a67 (diff)
downloadydb-e83c481c67c6d22053de832f656e049faeab0f80.tar.gz
Fix EvaluateExpr for optional types
-rw-r--r--ydb/core/kqp/provider/yql_kikimr_exec.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/provider/yql_kikimr_exec.cpp b/ydb/core/kqp/provider/yql_kikimr_exec.cpp
index c7d1baa892..8272c83f0a 100644
--- a/ydb/core/kqp/provider/yql_kikimr_exec.cpp
+++ b/ydb/core/kqp/provider/yql_kikimr_exec.cpp
@@ -519,7 +519,7 @@ private:
auto typeAnn = resInput->GetTypeAnn();
const auto kind = resInput->GetTypeAnn()->GetKind();
- const bool data = kind != ETypeAnnotationKind::Flow && kind != ETypeAnnotationKind::Stream && kind != ETypeAnnotationKind::Optional;
+ const bool data = kind != ETypeAnnotationKind::Flow && kind != ETypeAnnotationKind::Stream;
auto node = ctx.WrapByCallableIf(kind != ETypeAnnotationKind::Stream, "ToStream",
ctx.WrapByCallableIf(data, "Just", std::move(resInput)));