Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id F119F200C41 for ; Fri, 10 Mar 2017 03:41:41 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id EF850160B8A; Fri, 10 Mar 2017 02:41:41 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 4E87C160B75 for ; Fri, 10 Mar 2017 03:41:41 +0100 (CET) Received: (qmail 7737 invoked by uid 500); 10 Mar 2017 02:41:40 -0000 Mailing-List: contact yarn-issues-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list yarn-issues@hadoop.apache.org Received: (qmail 7722 invoked by uid 99); 10 Mar 2017 02:41:40 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Mar 2017 02:41:40 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id E9C091A7AA1 for ; Fri, 10 Mar 2017 02:41:39 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.451 X-Spam-Level: * X-Spam-Status: No, score=1.451 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_NEUTRAL=0.652] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id qc59x5u8qt6e for ; Fri, 10 Mar 2017 02:41:39 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id CDAF05FBC1 for ; Fri, 10 Mar 2017 02:41:38 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 4EDFAE086A for ; Fri, 10 Mar 2017 02:41:38 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 03B7C243AA for ; Fri, 10 Mar 2017 02:41:38 +0000 (UTC) Date: Fri, 10 Mar 2017 02:41:38 +0000 (UTC) From: "Huangkaixuan (JIRA)" To: yarn-issues@hadoop.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (YARN-6289) Fail to achieve data locality when runing MapReduce and Spark on HDFS MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 10 Mar 2017 02:41:42 -0000 [ https://issues.apache.org/jira/browse/YARN-6289?page=3Dcom.atlassian.= jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D15904= 296#comment-15904296 ]=20 Huangkaixuan commented on YARN-6289: ------------------------------------ Thanks [~leftnoteasy] 1=E3=80=81MR can get the locations of a block through FileSystem.getFileBlo= ckLocations. Usually MR applications use FileSystem.getFileBlockLocations t= o compute splits, but I haven't seen it in the default Yarn scheduling poli= cy (FIFO) 2=E3=80=81All nodes in the experiment are in the same rack, and all tasks a= re rack-local. RackAwareness will not affect the experimental results 3=E3=80=81the task failed to achieve data locality, even though there is no= other job running on the cluster at the same time. it seems that Yarn didn= =E2=80=99t attempt to allocate containers with data locality in the default= scheduling mode > Fail to achieve data locality when runing MapReduce and Spark on HDFS > --------------------------------------------------------------------- > > Key: YARN-6289 > URL: https://issues.apache.org/jira/browse/YARN-6289 > Project: Hadoop YARN > Issue Type: Bug > Components: distributed-scheduling > Environment: Hardware configuration > CPU: 2 x Intel(R) Xeon(R) E5-2620 v2 @ 2.10GHz /15M Cache 6-Core 12-Threa= d=20 > Memory: 128GB Memory (16x8GB) 1600MHz > Disk: 600GBx2 3.5-inch with RAID-1 > Network bandwidth: 968Mb/s > Software configuration > Spark-1.6.2=09Hadoop-2.7.1=20 > Reporter: Huangkaixuan > Attachments: Hadoop_Spark_Conf.zip, YARN-DataLocality.docx > > > When running a simple wordcount experiment on YARN, I noticed that the ta= sk failed to achieve data locality, even though there is no other job runni= ng on the cluster at the same time. The experiment was done in a 7-node (1 = master, 6 data nodes/node managers) cluster and the input of the wordcount = job (both Spark and MapReduce) is a single-block file in HDFS which is two-= way replicated (replication factor =3D 2). I ran wordcount on YARN for 10 t= imes. The results show that only 30% of tasks can achieve data locality, wh= ich seems like the result of a random placement of tasks. The experiment de= tails are in the attachment, and feel free to reproduce the experiments. -- This message was sent by Atlassian JIRA (v6.3.15#6346) --------------------------------------------------------------------- To unsubscribe, e-mail: yarn-issues-unsubscribe@hadoop.apache.org For additional commands, e-mail: yarn-issues-help@hadoop.apache.org