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