Hi Dasraj, Could you please specify where is the clusterClient.run() method and how does it submit a job to a cluster? Is the clusterClient your custom code?
Any details will help us pin down the problem. One thing that is worth looking at is the release-notes of 1.11 [1]. There you will find all the user-facing changes that came with the release. For example, one note that may be relevant to you is [2]. Cheers, Kostas [1] https://ci.apache.org/projects/flink/flink-docs-stable/release-notes/flink-1.11.html [2] https://ci.apache.org/projects/flink/flink-docs-stable/release-notes/flink-1.11.html#web-submission-behaves-the-same-as-detached-mode On Tue, Aug 4, 2020 at 9:07 AM dasraj <raj-kumar-...@microfocus.com> wrote: > > 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/
