You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2014/12/08 19:32:12 UTC

[jira] [Created] (SAMZA-491) Support a non-default queue in YARN

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)