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

Attachment: smime.p7s
Description: S/MIME cryptographic signature

Reply via email to