Hi Ron,
What version are you using? For 0.9, you need to set it outside your code
with the SPARK_YARN_QUEUE environment variable.
-Sandy
On Mon, May 19, 2014 at 9:29 PM, Ron Gonzalez <zlgonza...@yahoo.com> wrote:
> Hi,
> How does one submit a spark job to yarn and specify a queue?
> The code that successfully submits to yarn is:
>
> val conf = new SparkConf()
> val sc = new SparkContext("yarn-client", "Simple App", conf)
>
> Where do I need to specify the queue?
>
> Thanks in advance for any help on this...
>
> Thanks,
> Ron
>
