通过zeppelin调用脚本，提交Flink任务

怼烎@ 2022-12-13 14:24 134阅读 0赞

一，环境准备，我们在一个节点上部署zeppelin跟Flink。

zeppelin配置（啥也没改）：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70][]

二，在节点创建脚本

vim dwd-task2.sh

> \#bash
> 
> echo "开始dwd任务..."  
> $\{FLINK\_HOME\}/bin/flink run  -d -c com.sjb.dev.dwd.DwdEtl\_flatMap ./flink-neiwang-dev-1.0-SNAPSHOT-shade.jar  
> echo "任务开始执行......$0,$1,$3"

参考传参：[https://www.runoob.com/linux/linux-shell-passing-arguments.html][https_www.runoob.com_linux_linux-shell-passing-arguments.html]

三，执行zeppelin任务，查看结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1][]

四，如果要跨越节点的话：

都是通过SSH脚本命令：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70]: /images/20221123/c70e43c00dcc472395df1493872628f6.png
[https_www.runoob.com_linux_linux-shell-passing-arguments.html]: https://www.runoob.com/linux/linux-shell-passing-arguments.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1]: /images/20221123/6a1acfd21f1d4a4dbe55530032800083.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2]: /images/20221123/429f6c28d55e419995b978f30d9b6e92.png