Hi Thomas, I've got a few questions that will hopefully help get to find an answer:
What job properties are you trying to change? Something like parallelism? What mode is your job running in? i.e., Session, Per-Job, or Application? Can you also describe how you're redeploying the job? Are you using the Native Kubernetes integration or Standalone (i.e. writing k8s manifest files yourself)? It sounds like you are using the Flink CLI as well, is that correct? Thanks, Austin On Wed, Jul 21, 2021 at 4:05 AM Thms Hmm <thms....@gmail.com> wrote: > Hey, > > we have some application clusters running on Kubernetes and explore the HA > mode which is working as expected. When we try to upgrade a job, e.g. > trigger a savepoint, cancel the job and redeploy, Flink is not restarting > from the savepoint we provide using the -s parameter. So all state is lost. > > If we just trigger the savepoint without canceling the job and redeploy > the HA mode picks up from the latest savepoint. > > But this way we can not upgrade job properties as they were picked up from > the savepoint as it seems. > > Is there any advice on how to do upgrades with HA enabled? > > Flink version is 1.12.2. > > Thanks for your help. > > Kr thomas >
