flink命令行参数启动

时间:2025-04-09 07:12:05

flink服务操作

业务中使用flink来统计不同维度的数据,记录下使用中遇到的问题(包括jar包的启动、停止、获取命令行参数)。

1、flink 启动

 bin/flink run -d   -argKey argValue 

程序获取 命令行传入的参数

 ParameterTool parameters = ParameterTool.fromArgs(args);
 String runEnv = parameters.get("runEnv",DEFAULT_ENV);

2、flink stop(flink停止任务)

 bin/flink stop jobID

3、flink list(列出flink的任务)

 bin/flink list