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 D692F1853B for ; Thu, 17 Dec 2015 19:10:06 +0000 (UTC) Received: (qmail 38000 invoked by uid 500); 17 Dec 2015 19:10:01 -0000 Delivered-To: apmail-hadoop-mapreduce-user-archive@hadoop.apache.org Received: (qmail 37890 invoked by uid 500); 17 Dec 2015 19:10:01 -0000 Mailing-List: contact user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@hadoop.apache.org Received: (qmail 37874 invoked by uid 99); 17 Dec 2015 19:10:01 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 17 Dec 2015 19:10:01 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id AEE6D18046D for ; Thu, 17 Dec 2015 19:10:00 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.879 X-Spam-Level: ** X-Spam-Status: No, score=2.879 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 3NxNlBcYvQbz for ; Thu, 17 Dec 2015 19:09:59 +0000 (UTC) Received: from mail-yk0-f180.google.com (mail-yk0-f180.google.com [209.85.160.180]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id D8D5E2148B for ; Thu, 17 Dec 2015 19:09:58 +0000 (UTC) Received: by mail-yk0-f180.google.com with SMTP id p130so30807820yka.1 for ; Thu, 17 Dec 2015 11:09:58 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :cc:content-type; bh=080uy9HJd9gFG1ucWx7hBhSFn4yqy+wk6xN7WoX/6+4=; b=okJCv+dwTYSKm7io9hOmkD19RSXBYo6Z0+yub+1151Zg45zOUpV6CS51rn8JRobwVC L0hyHfauV6k+mqd01AJUSlJdfIsjTKq9QvDVsAtlsyvz4J/ay8tqHLKRS+hyK0mi7lZr nd4zkuZFMiHbVkbVdB+w1sAIWcU/2qejv1nMIjNo8iWFUqKgjzVxpwaLMGMSWgc8927W yNFxiXvDOOnSXiLFyYfTqAtLgP2o84psWkZgWxGGYPkc0XpsMo3XwuI2TWmPShxOhz2i JBf8wk9f2m6cnKgGD4cqHbMq1Z+5GjRKdMjkm4UzOWAaJDZsys7r71vR9aX6pIH5bt6b tJ+w== MIME-Version: 1.0 X-Received: by 10.129.110.84 with SMTP id j81mr33320510ywc.151.1450379397961; Thu, 17 Dec 2015 11:09:57 -0800 (PST) Received: by 10.37.215.195 with HTTP; Thu, 17 Dec 2015 11:09:57 -0800 (PST) In-Reply-To: References: Date: Thu, 17 Dec 2015 14:09:57 -0500 Message-ID: Subject: Re: Running multiple copies of each task From: Sultan Alamro To: Namikaze Minato Cc: user@hadoop.apache.org Content-Type: multipart/alternative; boundary=001a1149298cce229905271cc4cb --001a1149298cce229905271cc4cb Content-Type: text/plain; charset=UTF-8 Thanks Namikaze! Another question: New tasks in hadoop always have higher priority than speculative tasks. Does anyone know how and where I can change this priority? Thanks, Sultan On Thu, Dec 3, 2015 at 7:46 AM, Namikaze Minato wrote: > I think you are looking for mapreduce.reduce.speculative > Be careful, for some reason, this fell into my spam folder. > > Regards, > LLoyd > > On 3 December 2015 at 01:05, Sultan Alamro > wrote: > > Hi there, > > > > I have been looking at the hadoop source code 2.6.0 trying to understand > the > > low level details and how the framework is actually working. > > > > I have a simple idea and I am trying to figure out where and how the idea > > can be implemented. The idea can be described in one sentence: "Running > > multiple copies of each task". However, implementing the idea is not as > > simple as I think. > > > > What I am aware of is that I only need to modify a few classes. But, > which > > classes? > > > > I just need someone to guide me to the right direction. > > > > > > Best, > > Sultan > --001a1149298cce229905271cc4cb Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Thanks Namikaze!

Another quest= ion:

New tasks in hadoop always have higher priority than speculativ= e tasks.
Does anyone know how and where I can change this priority?

Thanks,
Sultan

=

On Thu, Dec 3, 20= 15 at 7:46 AM, Namikaze Minato <lloydsensei@gmail.com> w= rote:
I think you are looking for mapredu= ce.reduce.speculative
Be careful, for some reason, this fell into my spam folder.

Regards,
LLoyd

On 3 December 2015 at 01:05, Sultan Alamro <sultan.alamro@gmail.com> wrote:
> Hi there,
>
> I have been looking at the hadoop source code 2.6.0 trying to understa= nd the
> low level details and how the framework is actually working.
>
> I have a simple idea and I am trying to figure out where and how the i= dea
> can be implemented. The idea can be described in one sentence: "R= unning
> multiple copies of each task". However, implementing the idea is = not as
> simple as I think.
>
> What I am aware of is that I only need to modify a few classes. But, w= hich
> classes?
>
> I just need someone to guide me to the right direction.
>
>
> Best,
> Sultan

--001a1149298cce229905271cc4cb--