Hi, Currently we are using Flink 1.9.2 in our project and we are submitting Job from jar. below is that code we are using currently for jobsubmission:
clusterClient.setDetached(true); clusterClient.run(packagedProgram, Integer.valueOf(params.get(Constants.PARAMS_PARALLELISM))); After upgrading it to Flink 1.11.1, above piece of code is not working. Also new packagedProgram constructor is expecting "Configuration" as parameter. How can we change that to work for our needs? Thanks, -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
