登录    关于
马育民老师的博客

马育民的博客

QQ:65242847

linux crontab 定时执行 flink

编辑启动脚本

编辑启动 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

表示添加一个新的定时任务

注意: 必须要 保存退出


原文出处:https://malaoshi.top/show_1IX2TlsCmIiB.html