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

时间:2024-03-16 22:31:29

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

zeppelin配置(啥也没改):

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

二,在节点创建脚本

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

 

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

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

四,如果要跨越节点的话:

都是通过SSH脚本命令:

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