Return-Path: Delivered-To: apmail-hadoop-common-user-archive@www.apache.org Received: (qmail 12500 invoked from network); 21 Oct 2010 21:33:10 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 21 Oct 2010 21:33:10 -0000 Received: (qmail 96515 invoked by uid 500); 21 Oct 2010 21:33:08 -0000 Delivered-To: apmail-hadoop-common-user-archive@hadoop.apache.org Received: (qmail 96430 invoked by uid 500); 21 Oct 2010 21:33:08 -0000 Mailing-List: contact common-user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: common-user@hadoop.apache.org Delivered-To: mailing list common-user@hadoop.apache.org Received: (qmail 95975 invoked by uid 99); 21 Oct 2010 21:33:07 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Oct 2010 21:33:07 +0000 X-ASF-Spam-Status: No, hits=2.9 required=10.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_NONE,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: local policy) Received: from [209.85.212.176] (HELO mail-px0-f176.google.com) (209.85.212.176) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Oct 2010 21:33:01 +0000 Received: by pxi5 with SMTP id 5so27710pxi.35 for ; Thu, 21 Oct 2010 14:32:39 -0700 (PDT) MIME-Version: 1.0 Received: by 10.142.12.1 with SMTP id 1mr1261742wfl.400.1287696758114; Thu, 21 Oct 2010 14:32:38 -0700 (PDT) Received: by 10.220.198.197 with HTTP; Thu, 21 Oct 2010 14:32:37 -0700 (PDT) In-Reply-To: References: Date: Thu, 21 Oct 2010 14:32:37 -0700 Message-ID: Subject: Re: Setting num reduce tasks From: Alex Kozlov To: common-user@hadoop.apache.org Content-Type: multipart/alternative; boundary=000e0cd2442cd889ee049327437a X-Virus-Checked: Checked by ClamAV on apache.org --000e0cd2442cd889ee049327437a Content-Type: text/plain; charset=ISO-8859-1 It looks like you do not pass the Configuration object correctly. Do you use old or new (mapreduce) API? Do you have something like Job job = new Job(conf, "My job with " + conf.get("mapred.reduce.tasks") + " reducers"); to create the job? Is it OK to share you job creation code? Alex K On Thu, Oct 21, 2010 at 2:25 PM, Matt Tanquary wrote: > Hi Alex, > > Yes, I confirmed from those locations that the job is setting the reducers > to 1. > > Thanks > > On Thu, Oct 21, 2010 at 1:45 PM, Alex Kozlov wrote: > > > Hi Matt, it might be that the parameter does not end up in the final > > configuration for a number of reasons. Can you check the job config xml > in > > jt:/var/log/hadoop/history or in the JT UI and see what the > > mapred.reduce.tasks setting is? -- Alex K > > > > On Thu, Oct 21, 2010 at 1:39 PM, Matt Tanquary > >wrote: > > > > > I am using the following to set my number of reduce tasks, however when > I > > > run my job it's always using just 1 reducer. > > > > > > conf.setInt("mapred.reduce.tasks", 20); > > > > > > 1 reducer will never finish this job. Please help me to understand why > > the > > > setting I choose is not used. > > > > > > Thanks, > > > -M@ > > > > > > > > > -- > Have you thanked a teacher today? ---> http://www.liftateacher.org > --000e0cd2442cd889ee049327437a--