Return-Path: X-Original-To: apmail-hadoop-common-user-archive@www.apache.org Delivered-To: apmail-hadoop-common-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 CBC59D831 for ; Mon, 15 Oct 2012 22:19:05 +0000 (UTC) Received: (qmail 39325 invoked by uid 500); 15 Oct 2012 22:19:01 -0000 Delivered-To: apmail-hadoop-common-user-archive@hadoop.apache.org Received: (qmail 39229 invoked by uid 500); 15 Oct 2012 22:19:01 -0000 Mailing-List: contact user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@hadoop.apache.org Delivered-To: mailing list user@hadoop.apache.org Received: (qmail 39222 invoked by uid 99); 15 Oct 2012 22:19:01 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Oct 2012 22:19:01 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of harsh@cloudera.com designates 209.85.223.176 as permitted sender) Received: from [209.85.223.176] (HELO mail-ie0-f176.google.com) (209.85.223.176) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Oct 2012 22:18:54 +0000 Received: by mail-ie0-f176.google.com with SMTP id k11so10240397iea.35 for ; Mon, 15 Oct 2012 15:18:34 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type:content-transfer-encoding:x-gm-message-state; bh=VmU75+g6XQ84gYf0MYkb/hraRF1ZlvVMp+6KGaPqP98=; b=nrZCzI+VQiksnqwTjyGVOZQ1QynACRnyHYafXIy916laBJEc4g6CAea7rl2PwF5OUD jgsrs9VpEGGF3+VW14KemnqBVETBnWog1cEA3t7lWQG/jeA8lKZX3b9eXnaEr2K31PDi ePMsmBe/hljqUx8QhySPt01DnQDKFjNbTFALzTWKtMLL2CczbDIJBJczfgZWjREa6aLi txTpsV8d5PjVcZKFpoNDSaz8AXtUW7M5ybKmy14scNEty8HqnCm2+ALNraLgl95olIQB PRroEexGu0CNT7gOdzhV2jInz/dAOb1uRMPZGDjOgX+ncJv7ESff2eLnwFUiclEfRSSM 2prw== Received: by 10.50.15.132 with SMTP id x4mr9998420igc.58.1350339514325; Mon, 15 Oct 2012 15:18:34 -0700 (PDT) MIME-Version: 1.0 Received: by 10.64.77.232 with HTTP; Mon, 15 Oct 2012 15:18:14 -0700 (PDT) In-Reply-To: References: <6203AF4C-72E6-43C7-B712-0CF2CD63BA81@gmail.com> From: Harsh J Date: Tue, 16 Oct 2012 03:48:14 +0530 Message-ID: Subject: Re: Fair scheduler. To: user@hadoop.apache.org Content-Type: text/plain; charset=windows-1252 Content-Transfer-Encoding: quoted-printable X-Gm-Message-State: ALoCoQkNNcgDxcW3SeoFMLc8+8nonGuKooe/5Nzt+yxE8tkWGggA5BbQfdvUfNyU43spOhmKQOPB X-Virus-Checked: Checked by ClamAV on apache.org Hi Patai, Reply inline. On Tue, Oct 16, 2012 at 2:57 AM, Patai Sangbutsarakum wrote: > Thanks for input, > > I am reading the document; i forget to mention that i am on cdh3u4. That version should have the support for all of this. >> If you point your poolname property to mapred.job.queue.name, then you >> can leverage the Per-Queue ACLs > > Is that mean if i plan to 3 pools of fair scheduler, i have to > configure 3 queues of capacity scheduler. in order to have each pool > can leverage Per-Queue ACL of each queue.? Queues are not hard-tied into CapacityScheduler. You can have generic queues in MR. And FairScheduler can bind its Pool concept into the Queue configuration. All you need to do is the following: 1. Map FairScheduler pool name to reuse queue names itself: mapred.fairscheduler.poolnameproperty set to 'mapred.job.queue.name' 2. Define your required queues: mapred.job.queues set to "default,foo,bar" for example, for 3 queues: default, foo and bar. 3. Define Submit ACLs for each Queue: mapred.queue.default.acl-submit-job set to "patai,foobar users,adm" (usernames groupnames) mapred.queue.foo.acl-submit-job set to "spam eggs" Likewise for remaining queues, as you need it=85 4. Enable ACLs and restart JT. mapred.acls.enabled set to "true" 5. Users then use the right API to set queue names before submitting jobs, or use -Dmapred.job.queue.name=3Dvalue via CLI (if using Tool): http://hadoop.apache.org/docs/stable/api/org/apache/hadoop/mapred/JobConf.h= tml#setQueueName(java.lang.String) 6. Done. Let us know if this works! --=20 Harsh J