编辑启动脚本
编辑启动 flink 程序脚本
vim /program/timer_flink.sh
内容如下:
#/bin/bash
# 必须有此句,crontab有其自己的环境变量,不会用系统的环境变量,不加此句不会执行flink任务
source /etc/profile
flink run -m yarn-cluster /program/flink-1.12.5/examples/batch/WordCount.jar --input hdfs://hadoop1:8020/test2/data.txt --output hdfs://hadoop1:8020/flink_result21
增加可执行权限:
chmod 777 /program/timer_flink.sh
关键
在脚本中,必须有下面这句,crontab有其自己的环境变量,不会用系统的环境变量,不加此句就找不到 hadoop、flink等环境变量,就不会执行flink任务
source /etc/profile
设置定时
输入下面命令:
crontab -e
内容如下:
* * * * * /program/timer_flink.sh
然后 ESC-> :->wq 保存退出,提示如下:
crontab: installing new crontab
表示添加一个新的定时任务
注意: 必须要 保存退出