一,环境准备,我们在一个节点上部署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任务

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-05-09
  • 2022-12-23
  • 2021-09-23
  • 2021-07-15
  • 2022-12-23
  • 2022-01-25
猜你喜欢
  • 2021-11-04
  • 2022-12-23
  • 2021-04-19
  • 2022-02-09
  • 2022-12-23
  • 2022-01-01
  • 2021-09-17
相关资源
相似解决方案