Return-Path: X-Original-To: apmail-hadoop-mapreduce-user-archive@minotaur.apache.org Delivered-To: apmail-hadoop-mapreduce-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3434FD596 for ; Sun, 4 Nov 2012 20:18:47 +0000 (UTC) Received: (qmail 58305 invoked by uid 500); 4 Nov 2012 20:18:42 -0000 Delivered-To: apmail-hadoop-mapreduce-user-archive@hadoop.apache.org Received: (qmail 58012 invoked by uid 500); 4 Nov 2012 20:18:42 -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 58005 invoked by uid 99); 4 Nov 2012 20:18:42 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 04 Nov 2012 20:18:42 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of aseem.iiith@gmail.com designates 74.125.83.48 as permitted sender) Received: from [74.125.83.48] (HELO mail-ee0-f48.google.com) (74.125.83.48) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 04 Nov 2012 20:18:34 +0000 Received: by mail-ee0-f48.google.com with SMTP id b45so3079559eek.35 for ; Sun, 04 Nov 2012 12:18:14 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=wUsWJI6kUe0B0p5FOkvc00k3wCevcZouIHaajzqr5tc=; b=D2o9ElZWxbcm627Hm3kHYP6oUy2INBpE0vC7uJfZCs60tvV/8lfwuaQekeuF1K5Aiw AEXNqHvZhtIYTCXPBLk3XiGRDqpwIgCMRT8kG7Mk4VLoCA5Qh6/q8UVxEYhy+wGgoF77 WWxyxLyeg6y6xVRJ+H/BldDcnuUHVYeRV5kighaQZrG5z4CPAOsqhjOY+VAOWFCtRdNx IROeMoZLBsj8wK5iWEZmLDFH6ndS4fqT143d4R7U32ASPcqb88B3a5UvYCqWYZp00MTD wwKL0PN/udePpAp8GVG2BbdRi5qsVo8IAcUfm9bnywdUJ+BEXYNSdF7yIdhYLxbORFTU 5Agw== MIME-Version: 1.0 Received: by 10.14.179.136 with SMTP id h8mr29300996eem.7.1352060294536; Sun, 04 Nov 2012 12:18:14 -0800 (PST) Received: by 10.14.134.11 with HTTP; Sun, 4 Nov 2012 12:18:14 -0800 (PST) Date: Mon, 5 Nov 2012 01:48:14 +0530 Message-ID: Subject: Task does not enter reduce function after secondary sort From: Aseem Anand To: user@hadoop.apache.org Content-Type: multipart/alternative; boundary=047d7b603e92921f5a04cdb11169 X-Virus-Checked: Checked by ClamAV on apache.org --047d7b603e92921f5a04cdb11169 Content-Type: text/plain; charset=ISO-8859-1 Hi, I am using a Secondary Sort for my Hadoop program. My map function emits (Text,NullWritable) where Text contains the composite key and appropriate comparison functions are made and a custom Partitioner . These seem to be working fine. I have been struggling with the problem that these values are not being received by the reduce function and instead automatically get written to the hdfs in x number of files where x is the number of reducers. I have made sure the reduce function is set to my Reduce function and not identity reduce. Can someone please explain this behavior and what could be possibly wrong ? Thanks & Regards, Aseem --047d7b603e92921f5a04cdb11169 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi,

I am using a Secondary Sort for my Hadoop program. My map function = emits (Text,NullWritable) where Text contains the composite key and appropr= iate comparison functions are made and a custom Partitioner . These seem to= be working fine.

I have been struggling with the problem that these valu= es are not being received by the reduce function and instead automatically = get written to the hdfs in x number of files where x is the number of reduc= ers. I have made sure the reduce function is set to my Reduce function and = not identity reduce.

Can someone please explain this behavior and what could= be possibly wrong ?=A0

Thanks & Regards,

Aseem

--047d7b603e92921f5a04cdb11169--