You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@zeppelin.apache.org by "Sarah Cho (Jira)" <ji...@apache.org> on 2022/02/04 02:11:00 UTC

[jira] [Created] (ZEPPELIN-5650) Zeppelin does not support LOAD/UNLOAD MODULE command for flink interpreter

Sarah Cho created ZEPPELIN-5650:
-----------------------------------

             Summary: Zeppelin does not support LOAD/UNLOAD MODULE command for flink interpreter
                 Key: ZEPPELIN-5650
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-5650
             Project: Zeppelin
          Issue Type: Bug
          Components: flink
         Environment: zeppelin 0.10.1 & flink 1.13.5
            Reporter: Sarah Cho
         Attachments: Screen Shot 2022-02-04 at 10.55.46 AM.png

1. Flink supports pluggable modules and related commands(LOAD/UNLOAD MODULE, USE MODULES, SHOW FULL MODULES) since 2021.01

https://issues.apache.org/jira/browse/FLINK-21045

[https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/modules/#using-sql]

2. but I found that those commands are not supported in FlinkSqlInterpreter.

[https://github.com/apache/zeppelin/blob/master/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java#L206-L287]

3. Since those change above(1) was applied only from 1.13, it may have been intentionally omitted from interpreter. But in order to use hive built-in function using hive-connector, corresponding commands are required.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)