I suppose it would be possible to add a custom ‘job.version’ field to the samza job properties file, and then query for it via the REST /config endpoint on the ApplicationMananger, but I’m unclear how I find the RPC port for the ApplicationManager from the ResourceManager. The ResourceManager seems to only list the UI tracker endpoint proxy in its application REST endpoint.
I suppose I could scrape the port out of the HTML, but it seems like there should be a better way. Richard > On Sep 19, 2015, at 3:25 PM, Richard Lee <rd...@tivo.com> wrote: > > 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
