This is an automated email from the ASF dual-hosted git repository. guanhuali pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push: new c68182d4bc [MINOR] Update doc for flink 1.16 (#4572) c68182d4bc is described below commit c68182d4bc449b83c28883bd5ece098b60b7bf8c Author: Calvin Canh Tran <trandc...@gmail.com> AuthorDate: Wed Apr 26 18:01:39 2023 +0800 [MINOR] Update doc for flink 1.16 (#4572) Co-authored-by: calvin.tran <calvin.t...@grabtaxi.com> --- docs/interpreter/flink.md | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/docs/interpreter/flink.md b/docs/interpreter/flink.md index 0d70ef6491..c5a6af957a 100644 --- a/docs/interpreter/flink.md +++ b/docs/interpreter/flink.md @@ -144,13 +144,15 @@ docker run -u $(id -u) -p 8080:8080 --rm -v /mnt/disk1/flink-sql-cookbook-on-zep Download Flink 1.10 or afterwards (Scala 2.11 & 2.12 are both supported) -### Specific for Flink 1.15 +### Specific for Flink 1.15 and above Flink 1.15 is scala free and has changed its binary distribution. If you would like to make Zeppelin work with Flink 1.15, you need to do the following extra steps. * Move FLINK_HOME/opt/flink-table-planner_2.12-1.15.0.jar to FLINK_HOME/lib * Move FLINK_HOME/lib/flink-table-planner-loader-1.15.0.jar to FLINK_HOME/opt * Download flink-table-api-scala-bridge_2.12-1.15.0.jar and flink-table-api-scala_2.12-1.15.0.jar to FLINK_HOME/lib +Flink 1.16 introduces new `ClientResourceManager` for sql client, you need to move `FLINK_HOME/opt/flink-sql-client-1.16.0.jar` to `FLINK_HOME/lib` + ## Flink on Zeppelin Architecture <img src="{{BASE_PATH}}/assets/themes/zeppelin/img/docs-img/flink_architecture.png">