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)
