summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-05-14 16:38:48 +0300
committervvvv <[email protected]>2025-05-14 16:53:34 +0300
commitb78b05b5986a1525f0dc69dcc0887cd7e855a31c (patch)
treefd08839289abb79d15f6b759aef659c4f1a84bc6
parent504e540cc1f6dfa55c2fb585232d7241cb26f7ba (diff)
Fixed file alias YQL-19954
commit_hash:09460c70f00cff5f34ec1d2201385ec1fc4657f2
-rw-r--r--yql/essentials/core/type_ann/type_ann_core.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/yql/essentials/core/type_ann/type_ann_core.cpp b/yql/essentials/core/type_ann/type_ann_core.cpp
index cffa6e4290b..1dd3201171b 100644
--- a/yql/essentials/core/type_ann/type_ann_core.cpp
+++ b/yql/essentials/core/type_ann/type_ann_core.cpp
@@ -7740,7 +7740,9 @@ template <NKikimr::NUdf::EDataSlot DataSlot>
}
}
- auto udfInfo = ctx.Types.UdfModules.FindPtr(moduleName);
+ TStringBuf normalizedModuleName, normalizedFuncName;
+ YQL_ENSURE(SplitUdfName(cached.NormalizedName, normalizedModuleName, normalizedFuncName));
+ auto udfInfo = ctx.Types.UdfModules.FindPtr(normalizedModuleName);
TStringBuf fileAlias = udfInfo ? udfInfo->FileAlias : ""_sb;
auto ret = ctx.Expr.Builder(input->Pos())
.Callable("Udf")