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 A1B23DED5 for ; Mon, 10 Sep 2012 17:46:46 +0000 (UTC) Received: (qmail 4379 invoked by uid 500); 10 Sep 2012 17:46:43 -0000 Delivered-To: apmail-hadoop-mapreduce-user-archive@hadoop.apache.org Received: (qmail 4317 invoked by uid 500); 10 Sep 2012 17:46:42 -0000 Mailing-List: contact mapreduce-user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: mapreduce-user@hadoop.apache.org Delivered-To: mailing list mapreduce-user@hadoop.apache.org Received: (qmail 4307 invoked by uid 99); 10 Sep 2012 17:46:42 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Sep 2012 17:46:42 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=FSL_RCVD_USER,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (athena.apache.org: local policy) Received: from [209.85.160.48] (HELO mail-pb0-f48.google.com) (209.85.160.48) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 10 Sep 2012 17:46:36 +0000 Received: by pbbrq13 with SMTP id rq13so3559949pbb.35 for ; Mon, 10 Sep 2012 10:46:16 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=from:mime-version:content-type:subject:date:in-reply-to:to :references:message-id:x-mailer:x-gm-message-state; bh=B1omuUNBSFnuxpfd0m+OTo507ov/OCtV/0KV5pTZc9A=; b=pJPcaPgXV4+e6OsMefJHC8YdZIwVWaN2/CjTU98pFPB7jl15586AMLN3tXBl+qwgzT 69VdKnISBNoLVVUd7CgTwzDXAwUs+rrcNRyAyWgzS8NCZkJGLCV70NX6q9Ge4S8Hu7lH GZZ0HaeoLUFPFmv4VBdo9N8OsjL1Kapcofl4vpSr9Gw7Kx94f+MglEN9XW4YXXh6ZWbA A8a5R0Lz38R1r34Sl4tiyDEReGjNid+VftF2pEuec3+R7xqfc3JAGAvqsrriUoASlUUP uGJBYls//JgjfnOI/Ar3MkdHBXKOY/dl/Ld3Vys5f7JmqIsbAUCyrMkk9VFTqYeaArRk Wppg== Received: by 10.68.225.104 with SMTP id rj8mr6843677pbc.97.1347299176060; Mon, 10 Sep 2012 10:46:16 -0700 (PDT) Received: from [10.10.11.118] (host1.hortonworks.com. [70.35.59.2]) by mx.google.com with ESMTPS id qw6sm8396419pbc.26.2012.09.10.10.46.15 (version=TLSv1/SSLv3 cipher=OTHER); Mon, 10 Sep 2012 10:46:15 -0700 (PDT) From: Vinod Kumar Vavilapalli Mime-Version: 1.0 (Apple Message framework v1278) Content-Type: multipart/signed; boundary="Apple-Mail=_46B971DF-53FD-48C3-8044-FF8A96D8DA4D"; protocol="application/pgp-signature"; micalg=pgp-sha1 Subject: Re: Counters across all jobs Date: Mon, 10 Sep 2012 10:46:13 -0700 In-Reply-To: To: mapreduce-user@hadoop.apache.org References: Message-Id: X-Mailer: Apple Mail (2.1278) X-Gm-Message-State: ALoCoQkZtIDSoRDh5qzUEvubNqO2TCnnkzmc2D63/bdPMP6465KzG1ZrLauD5wE5LM1KrKs5oCUf X-Virus-Checked: Checked by ClamAV on apache.org --Apple-Mail=_46B971DF-53FD-48C3-8044-FF8A96D8DA4D Content-Type: multipart/alternative; boundary="Apple-Mail=_E223EF42-D955-4CD3-940F-79881AB49275" --Apple-Mail=_E223EF42-D955-4CD3-940F-79881AB49275 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=iso-8859-1 Counters are per-job in Hadoop MapReduce. You need an external = aggregator for such cross-job counters - for e.g. a node in Zookeeper. Also, is it just for display or your job-logic depends on this? If it is = the earlier, and if you don't have a problem with waiting till jobs = finish, you can do a post-process on the counters of all jobs and = calculate the aggregates. Thanks, +Vinod Kumar Vavilapalli Hortonworks Inc. http://hortonworks.com/ On Aug 28, 2012, at 1:20 AM, Kasi Subrahmanyam wrote: > Hi, >=20 > I have around 4 jobs running in a controller. > How can i have a single unique counter present in all the jobs and = incremented where ever used in a job? >=20 > For example:Consider a counter ACount. > If job1 is incrementing the counter by2 and job3 by 5 and job 4 by 6. > Can i have the counter displayed output in the jobtracker as > job1:2 > job2:2 > job3:7 > job4:13 >=20 > Thanks, > Subbu >=20 --Apple-Mail=_E223EF42-D955-4CD3-940F-79881AB49275 Content-Transfer-Encoding: 7bit Content-Type: text/html; charset=iso-8859-1

Counters are per-job in Hadoop MapReduce. You need an external aggregator for such cross-job counters - for e.g. a node in Zookeeper.

Also, is it just for display or your job-logic depends on this? If it is the earlier, and if you don't have a problem with waiting till jobs finish, you can do a post-process on the counters of all jobs and calculate the aggregates.

Thanks,
+Vinod Kumar Vavilapalli
Hortonworks Inc.
http://hortonworks.com/

On Aug 28, 2012, at 1:20 AM, Kasi Subrahmanyam wrote:

Hi,

I have around 4 jobs running in a controller.
How can i have a single unique counter present in all the jobs and incremented where ever used in a job?

For example:Consider a counter ACount.
If job1 is incrementing the counter by2 and job3 by 5 and job 4 by 6.
Can i have the  counter displayed output in the jobtracker as
job1:2
job2:2
job3:7
job4:13

Thanks,
Subbu


--Apple-Mail=_E223EF42-D955-4CD3-940F-79881AB49275-- --Apple-Mail=_46B971DF-53FD-48C3-8044-FF8A96D8DA4D Content-Transfer-Encoding: 7bit Content-Disposition: attachment; filename=signature.asc Content-Type: application/pgp-signature; name=signature.asc Content-Description: Message signed with OpenPGP using GPGMail -----BEGIN PGP SIGNATURE----- Version: GnuPG/MacGPG2 v2.0.17 (Darwin) iQEcBAEBAgAGBQJQTidlAAoJECVa31bDbF8PtUkIALQ3JnZRq7jGvXXJqIwn9Xj1 xtEfbuvTnXKutLfQwFEm6PtCMxq1/+BqDhm/EPqXGfcChg44MP3Ro8bnaJLksml7 ImdLTobtdCRsn7VFuQzjUT1VNQ8YPlXSJmG3a3UZ1n/Upfgq7Ss5bSkUfPAXO1ut 87NvpsWd7lV6zSdc6RIhs+apiwevmqU7aaJo0ZFsftxSAiiiRg0lhmR8nCP8SK15 XWts/a7852Y6dRO99gFBgqcL11iocjMn2WR8/HKO98S9jP5PGCOfVHssUdA8lS8n k7gFnDZdhpcHmN//HdRFcAzWjQX4YKZXomB4Rp0jbHhi1rr4nzcTzXUOBayVjaQ= =hVQ+ -----END PGP SIGNATURE----- --Apple-Mail=_46B971DF-53FD-48C3-8044-FF8A96D8DA4D--