本地IDEA环境，启动Flinkx，并给启动类CommandLine传递参数

介绍：在IDEA中，local模式启动Flinkx

1、上传flinkx文件夹到服务器

将flinkx文件夹复制到服务器的/work/flink/flinkx/目录下，即 $FLINKX_HOME=/work/flink/flinkx/flinkx

2、执行启动命令

cd $FLINKX_HOME ./bin/flinkx -mode local -job $FLINKX_HOME/flinkx-examples/examples/stream_example.json -pluginRoot $FLINKX_HOME/plugins -flinkconf $FLINKX_HOME/flinkconf

在执行flinkx脚本的最后一行命令

nohup $JAVA_RUN -cp $JAR_DIR $CLASS_NAME $@ &

$@ 传递给Launcher启动类的参数是：

-mode local -job /work/flink/flinkx/flinkx/flinkx-examples/examples/stream_example.json -pluginRoot /work/flink/flinkx/flinkx/plugins -flinkconf /work/flink/flinkx/flinkx/flinkconf

3、在本地环境IDEA中，配置Main启动类的Program arguments参数

设置com.dtstack.flinkx.Main启动类的Program arguments参数

-mode local -job D:\IdeaProjects\flink\flinkx\flinkx-examples\examples\stream_example.json -pluginRoot D:\IdeaProjects\flink\flinkx\plugins -flinkconf D:\IdeaProjects\flink\flinkx\flinkconf

 

4、Debug Main方法，查看传递过来的参数