Hi there- How do people track which version of a samza job is running in yarn? The job name and job id can’t be used, as they are used to create the checkpoint topic, etc. I’m looking for a way of determining if the current job running in yarn is the latest version, and if not, kill it and launch a newer version, picking up where the previous version left off.
There seems to be no ‘job version’ field anywhere obvious in either samza or yarn. Is there another approach I should use? Richard
smime.p7s
Description: S/MIME cryptographic signature