Return-Path: X-Original-To: apmail-crunch-user-archive@www.apache.org Delivered-To: apmail-crunch-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D941A1832B for ; Thu, 24 Sep 2015 19:12:27 +0000 (UTC) Received: (qmail 53458 invoked by uid 500); 24 Sep 2015 19:12:27 -0000 Delivered-To: apmail-crunch-user-archive@crunch.apache.org Received: (qmail 53415 invoked by uid 500); 24 Sep 2015 19:12:27 -0000 Mailing-List: contact user-help@crunch.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@crunch.apache.org Delivered-To: mailing list user@crunch.apache.org Received: (qmail 53405 invoked by uid 99); 24 Sep 2015 19:12:27 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 24 Sep 2015 19:12:27 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 39916C1326 for ; Thu, 24 Sep 2015 19:12:27 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.149 X-Spam-Level: *** X-Spam-Status: No, score=3.149 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 9onQexAw9BwI for ; Thu, 24 Sep 2015 19:12:26 +0000 (UTC) Received: from mail-yk0-f172.google.com (mail-yk0-f172.google.com [209.85.160.172]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 8FEC320604 for ; Thu, 24 Sep 2015 19:12:25 +0000 (UTC) Received: by ykdt18 with SMTP id t18so93922755ykd.3 for ; Thu, 24 Sep 2015 12:12:24 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:references:in-reply-to:from:date:message-id:subject:to :content-type; bh=thmpaAzegSHejcOi0Kv2iDb6HBwhZ3SiA0wvasgzNEI=; b=P6IfqBVWlOz+6R/NfjS96i1zvRzxJ9PHpxiqOkVnuBVHp9d/Lx0B3HYLqx88go+4L1 yGHAvdx6RYwdMNNqqaGxovZ/BKPsPG5ji9h10KmnxGKDhOcXOnSktvFvHtggWBxHQ++v oC+B+NPF971k8MgCZgrwUshFF/nEam4ivuwBgtfmemIypZ8WO7Mr5VCZ8zWKShnnnl79 JDgQVWYpppPKglmAnR/0Ky1A2gmx0ttsmetDBqCJYKlIMvEX9n6xIt0/OYXAgkmHTt6A wOGvs4j3RbNBQSsXkZcHtoa8eHSIOpGN7D1sw+fyOtHy1AsUQDl/01XhL4dUwFfWnKiT qtJA== X-Received: by 10.170.36.197 with SMTP id 188mr1229256yke.23.1443121944491; Thu, 24 Sep 2015 12:12:24 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: David Ortiz Date: Thu, 24 Sep 2015 19:12:15 +0000 Message-ID: Subject: Re: how to submit a crunch job to a specific queue To: user@crunch.apache.org Content-Type: multipart/alternative; boundary=001a113776b8de7ec205208302b8 --001a113776b8de7ec205208302b8 Content-Type: text/plain; charset=UTF-8 I find it easiest to set that parameter in the pipeline code, and make the name a command line arg for my app On Thu, Sep 24, 2015, 2:50 PM Josh Wills wrote: > Lucy, > > Does your classname extend the CrunchTool abstract class or implement the > Hadoop Tool interface and use ToolRunner.run(new Configuration(), new > ClassName(), args) to execute the job in the main method? That's how those > commandline args get parsed and passed in to the Configuration object. > > J > > On Thu, Sep 24, 2015 at 11:42 AM, Lucy Chen > wrote: > >> Hi, >> >> I am trying to configure my crunch job with a specific queue as >> following: >> >> hadoop jar my-crunch-app.jar classname >> -Dmapreduce.job.queuename=queue_name >> >> but it did not work, and the job was still submitted to the default >> queue. >> >> How can I change the queue name in either command line way or by >> setting the job conf in my crunch codes? >> >> Thanks! >> >> Lucy >> > > > > -- > Director of Data Science > Cloudera > Twitter: @josh_wills > --001a113776b8de7ec205208302b8 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

I find it easiest to set that parameter in the pipeline code= , and make the name a command line arg for my app


On Thu, Sep 24, 2015, 2:50 = PM=C2=A0Josh Wills <jwills@cloude= ra.com> wrote:
Lucy,

Does your classname extend the CrunchTool abst= ract class or implement the Hadoop Tool interface and use ToolRunner.run(ne= w Configuration(), new ClassName(), args) to execute the job in the main me= thod? That's how those commandline args get parsed and passed in to the= Configuration object.

J

On Thu, Sep 24, 2015 at 11:42 AM, Lucy Chen <lucychen2014fall@g= mail.com> wrote:
Hi,

=C2=A0 =C2=A0 I am trying to configure my c= runch job with a specific queue as following:

=C2= =A0 =C2=A0hadoop jar my-crunch-app.jar classname -Dmapreduce.job.queuename= =3Dqueue_name

=C2=A0 =C2=A0but it did not work, an= d the job was still submitted to the default queue.

=C2=A0 =C2=A0 How can I change the queue name in either command line way = or by setting the job conf in my crunch codes?

=C2= =A0 =C2=A0Thanks!

Lu= cy



--
Director of Data Science
Twitt= er: @josh_wills=
--001a113776b8de7ec205208302b8--