Hi Krishna,
I think the problem is that you are trying to pass in dynamic properties
(-Dconfig.file=dev.conf) to an already started the cluster. The Flink
cluster components or their JVMs need to know the env.java.opts at cluster
start up time and not when the Flink job is submitted. You can check
Hello All,
I have a Flink application that inherits configuration from
application.conf in the resources folder.
Now, I want to run this application on a cluster. I begin creating an fat
jar "mvn clean assembly".
This jar file is executed by executing the following command below
$FLINK_HOME/bin
