一,环境准备,我们在一个节点上部署zeppelin跟Flink。
zeppelin配置(啥也没改):
二,在节点创建脚本
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任务,查看结果
四,如果要跨越节点的话:
都是通过SSH脚本命令: