Hey Richard, The ApplicationReport returned by YarnClient.getApplications() or getApplicationReport(appId) includes the AM host and rpc port.
https://hadoop.apache.org/docs/r2.7.0/api/org/apache/hadoop/yarn/client/api/YarnClient.html#getApplications() https://hadoop.apache.org/docs/r2.7.0/api/org/apache/hadoop/yarn/client/api/YarnClient.html#getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId) On Sat, Sep 19, 2015 at 4:09 PM, Richard Lee <rd...@tivo.com> wrote: > 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 > > > >
