Return-Path: Delivered-To: apmail-hadoop-core-user-archive@www.apache.org Received: (qmail 98294 invoked from network); 16 Apr 2008 15:44:22 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 16 Apr 2008 15:44:22 -0000 Received: (qmail 66267 invoked by uid 500); 16 Apr 2008 15:44:17 -0000 Delivered-To: apmail-hadoop-core-user-archive@hadoop.apache.org Received: (qmail 66230 invoked by uid 500); 16 Apr 2008 15:44:17 -0000 Mailing-List: contact core-user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: core-user@hadoop.apache.org Delivered-To: mailing list core-user@hadoop.apache.org Received: (qmail 66221 invoked by uid 99); 16 Apr 2008 15:44:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Apr 2008 08:44:17 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [63.133.162.100] (HELO s04.c4d.visvo.com) (63.133.162.100) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Apr 2008 15:43:26 +0000 Received: from localhost (localhost [127.0.0.1]) by s04.c4d.visvo.com (Postfix) with ESMTP id B6D951838304 for ; Wed, 16 Apr 2008 10:45:49 -0500 (CDT) X-Virus-Scanned: Debian amavisd-new at s04.c4d.visvo.com Received: from s04.c4d.visvo.com ([127.0.0.1]) by localhost (localhost [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id ubicgHl5aGMC for ; Wed, 16 Apr 2008 10:45:43 -0500 (CDT) Received: from [192.168.1.229] (workstation04.visvo.com [192.168.1.229]) by s04.c4d.visvo.com (Postfix) with ESMTP id 76F8C1838301 for ; Wed, 16 Apr 2008 10:45:43 -0500 (CDT) Message-ID: <48061EAB.8030305@visvo.com> Date: Wed, 16 Apr 2008 10:43:39 -0500 From: Sagar Naik User-Agent: Thunderbird 2.0.0.6 (Windows/20070728) MIME-Version: 1.0 To: core-user@hadoop.apache.org Subject: Re: Aborting Map Function References: <16722552.post@talk.nabble.com> In-Reply-To: <16722552.post@talk.nabble.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Chaman Singh Verma wrote: > Hello, > > I am developing one application with MapReduce and in that whenever some > MapTask condition is > met, I would like to broadcast to all other MapTask to abort their work. I > am not quite sure whether > such broadcasting functionality currently exist in Hadoop MapReduce. Could > someone give some > hints. > > Although extending this functionality may be easy as all the slaves > periodically ping the master, > I was just thinking of piggybacking one bit information from the slave to > the master and master > may send this information to all the slaves in the next round. Any > suggestions to this approach ? > > Thanks. > > With Regards > > ----- > Chaman Singh Verma > Poona, India > One possible solution could be to use Counters (http://hadoop.apache.org/core/docs/r0.16.2/api/org/apache/hadoop/mapred/Counters.html) Though it is advisable to look into details of implementation of it, and see if it can be used for multi-process shared variable