flink1.17.2,在代码中使用下面的方式注册函数时不能使用using jar,必须把jar放到任务依赖里面,一旦使用using jar语法,那么会报下面的错误,使用sqlclient就可以使用,这是bug还是说是功能限制?
CREATE [TEMPORARY|TEMPORARY SYSTEM] FUNCTION
[IF NOT EXISTS] [catalog_name.][db_name.]function_name
AS identifier [LANGUAGE JAVA|SCALA|PYTHON]
[USING JAR ‘.jar’ [, JAR ‘.jar’]* ]
以下为热心网友提供的参考意见
楼主你好,看了你的描述,在代码中注册函数时,如果使用了 USING JAR
语法指定了 jar 文件,会出现报错,但是在使用 SQL Client 进行操作时,可以正常使用。这可能是由于 Flink 版本、使用方式或配置不同导致的问题,你可以升级Flink最新版本,然后确保你的jar文件已正确放置在任务依赖的位置,确保 Flink 配置中的 flink.execution.library-cache.default
和 flink.execution.library-cache.size
设置正确。
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/18632.html