Chris Riccomini created SAMZA-491:
-------------------------------------
Summary: Support a non-default queue in YARN
Key: SAMZA-491
URL: https://issues.apache.org/jira/browse/SAMZA-491
Project: Samza
Issue Type: Bug
Components: yarn
Affects Versions: 0.9.0
Reporter: Chris Riccomini
Fix For: 0.9.0
Samza always submits its jobs to YARN's default queue. We should make this
configurable.
I believe that the steps are:
1) Add a `yarn.queue` field to YarnConfig.
2) Update YarnJob.scala's submit() method to get the yarn queue, and use it in
the client.submitApplication() call.
3) Update ClientHelper.scala's submitApplication() method to take an optional
queue, and if it's set, add it to the ApplicationSubmissionContext, as I
described above.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
