If I deploy a job to Flink called "A"(set my
streamExecutionEnvironment.execute("A"), that checkpoints state.  Then I
cancel "A" and deploy the same job but call it "B", will it pick up A's
state?  Or is checkpointing key'd by the job name?

The reason I ask is I would like a way to reflect the version of the job
that is deployed in the flink UI somewhere, so that I know what is
running.  I put this in the jobname as a quick fix, but I'm concerned it
might affect checkpointing when I deploy a new version.  Is there a good
way to put the version of the job somewhere such that it gets reflected in
the UI?

Thanks!

Dan

Reply via email to