You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Angelo Kastroulis (Jira)" <ji...@apache.org> on 2022/10/11 01:45:00 UTC

[jira] [Created] (FLINK-29575) Can't Add Temporary Function USING JAR

Angelo Kastroulis created FLINK-29575:
-----------------------------------------

             Summary: 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


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)