getting error after upgrade Flink 1.11.1

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 i

Re: getting error after upgrade Flink 1.11.1

Hi Kostas, ClusterClient class is not our custom class it is in org.apache.flink.client.program package. i can see defination of ClusterClient has changed from 1.9.2 to 1.11.1 https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/java/org/apache/flink/client/program/ClusterClient.html <

Re: getting error after upgrade Flink 1.11.1

Hi Kostas, I am trying to migrate our code base to use new ClusterClient method for job submission. As you recommending to use new publicEvolving APIs, any doc or link for reference will be helpful. Thanks, -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/