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

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: flink

Environment

zeppelin 0.10.1 & flink 1.13.5

• Assignee: Unassigned
• Reporter: Sarah Cho
• Created: 04/Feb/22 02:10
• Updated: 04/Feb/22 02:10

Description

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.