Hi, Flink community I’m starter at Flink ,and don’t know how to passing parameters to my jar file, where I want to start the job in detached mode on the yarn cluster. Here is my shell code:
/usr/local/flink/bin/flink run -m yarn-cluster -d -p 3 ~/project/test/app/test.jar -runat=test 2>&1 In my jar file, the code will use different config.properties file by reading the “runat” CLI parameter, but I don’t know how to get this CLI parameter or could you please tell me if I’ve two environment one for testing and the other for production environment property files, how can I start it using cli option? Thanks a lot , Any help is appreciated. Chao fan
<<attachment: winmail.dat>>
