Return-Path: X-Original-To: apmail-hadoop-common-user-archive@www.apache.org Delivered-To: apmail-hadoop-common-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6753811ECF for ; Thu, 28 Aug 2014 06:15:55 +0000 (UTC) Received: (qmail 57339 invoked by uid 500); 28 Aug 2014 06:15:49 -0000 Delivered-To: apmail-hadoop-common-user-archive@hadoop.apache.org Received: (qmail 57217 invoked by uid 500); 28 Aug 2014 06:15:49 -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 57207 invoked by uid 99); 28 Aug 2014 06:15:49 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 Aug 2014 06:15:49 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_IMAGE_ONLY_20,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_REMOTE_IMAGE X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of sshi@pivotal.io designates 74.125.82.174 as permitted sender) Received: from [74.125.82.174] (HELO mail-we0-f174.google.com) (74.125.82.174) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 Aug 2014 06:15:45 +0000 Received: by mail-we0-f174.google.com with SMTP id u57so259444wes.5 for ; Wed, 27 Aug 2014 23:15:24 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:date :message-id:subject:from:to:content-type; bh=Iug7R1tozkHwcdWRWJLSZAQdQFe0HFQgb2qCOh/yMiU=; b=dxQDacG92anL26oep8XlnzrRtxmzsjBAjllFRYcIfqASwtI5o3+WUHXjneLeyTEZe+ rmfIUybcbIQUX04MOBX+6QXEglaz4A2d0wKKRTKDddFJTnAvcqq+WCjjrFvuBDz6aDpm ubUqJHrwrl9hV6GSCZjg8TL6pd+gMRhyWarhvvZ+yCDfWxzLr4M6PLZ2SUhszaYWgMzc 4JNVnu9rA3vOc6acJ97UGhfLJjN0WFVZO5fUNW4PsRhXSoFzt1MUXywOwxxhQz7i0MIv p0Qy5M0X8rSEUIbbAlhwO+fRXzflnJYFxP1HmVDuBnLz9pq94Za/IyvktO62gQZ7N1q0 C6wQ== X-Gm-Message-State: ALoCoQlaINnLBsKUddOwSvmuFgo9vFE2NlgLthqBOxIuazPeaMxrXdrLgXsZSKzmruGoqEzbwOsU MIME-Version: 1.0 X-Received: by 10.194.185.230 with SMTP id ff6mr296222wjc.120.1409206523866; Wed, 27 Aug 2014 23:15:23 -0700 (PDT) Received: by 10.217.157.5 with HTTP; Wed, 27 Aug 2014 23:15:23 -0700 (PDT) In-Reply-To: References: Date: Thu, 28 Aug 2014 14:15:23 +0800 Message-ID: Subject: Re: What happens when .....? From: Stanley Shi To: "user@hadoop.apache.org" Content-Type: multipart/alternative; boundary=047d7bb0398c454f330501aa760b X-Virus-Checked: Checked by ClamAV on apache.org --047d7bb0398c454f330501aa760b Content-Type: text/plain; charset=UTF-8 Normally MR job is used for batch processing. So I don't think this is a good use case here for MR. Since you need to run the program periodically, you cannot submit a single mapreduce job for this. An possible way is to create a cron job to scan the folder size and submit a MR job if necessary; On Wed, Aug 27, 2014 at 7:38 PM, Kandoi, Nikhil wrote: > Hi All, > > > > I have a system where files are coming in hdfs at regular intervals and I > perform an operation everytime the directory size goes above a particular > point. > > My Question is that when I submit a map reduce job, would it only work on > the files present at that point ?? > > > > Regards, > Nikhil Kandoi > > > -- Regards, *Stanley Shi,* --047d7bb0398c454f330501aa760b Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Normally MR job is used for batch processing. So I don'= ;t think this is a good use case here for MR.
Since you need to run the= program periodically, you cannot submit a single mapreduce job for this.= =C2=A0
An possible way is to create a cron job to scan the folder size and su= bmit a MR job if necessary;



On Wed, Aug 27, 2014 at 7:38 PM, K= andoi, Nikhil <Nikhil.Kandoi@emc.com> wrote:

Hi All,

=C2=A0

I have a system where files are coming in hdfs at re= gular intervals and I perform an operation everytime the directory size goe= s above a particular point.

My Ques= tion is that when I submit a map reduce job, would it only work on the file= s present at that point ??

=C2=A0

Regards,
Nikhil Kandoi

=C2=A0




--
Regard= s,
Stanley Shi,

--047d7bb0398c454f330501aa760b--