[
https://issues.apache.org/jira/browse/FLINK-29575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615418#comment-17615418
]
Xingbo Huang commented on FLINK-29575:
--------------------------------------
This feature is introduced in release-1.16, the version of flink you are using
is 1.15.1?
> Can't Add Temporary Function USING JAR
> --------------------------------------
>
> Key: FLINK-29575
> URL: https://issues.apache.org/jira/browse/FLINK-29575
> Project: Flink
> Issue Type: Bug
> Components: Documentation
> Affects Versions: 1.15.1
> Reporter: Angelo Kastroulis
> Priority: Minor
>
> In the create documentation for Flink SQL it says:
> {code:java}
> CREATE [TEMPORARY|TEMPORARY SYSTEM] FUNCTION
> [IF NOT EXISTS] [catalog_name.][db_name.]function_name
> AS identifier [LANGUAGE JAVA|SCALA|PYTHON]
> [USING JAR '<path_to_filename>.jar' [, JAR '<path_to_filename>.jar']* ]
> {code}
> However, this:
> {code:java}
> CREATE TEMPORARY SYSTEM FUNCTION MyFunc AS
> 'com.ballista.my.classpath.MyFunc' LANGUAGE SCALA
> USING JAR 'path-to-my.jar'{code}
> Throws this exception:
> {code:java}
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.sql.parser.impl.ParseException: Encountered "USING" at line
> 3, column 3.
> Was expecting one of:
> <EOF>
> ";" ... {code}
> This works:
> {code:java}
> ADD JAR 'path-to-my.jar';
> CREATE TEMPORARY SYSTEM FUNCTION MyFunc AS
> com.ballista.my.classpath.MyFunc' LANGUAGE SCALA;{code}
> Is this a bug in the code, or is the documentation perhaps not up to date?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
