Mailing-List: contact common-user-help@hadoop.apache.org; run by ezmlm
Precedence: bulk
Reply-To: common-user@hadoop.apache.org
Received-SPF: pass (athena.apache.org: domain of dongogo@gmail.com designates
 209.85.222.196 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type;
        b=U1t7Tq+TM39vQlD0E8tx3oqGEV9PIsRwDbtj7yhGzqj7YxD7xFPjtoA/FtvWKH/JaS
         m+425LqNrDwNeMRzI7LBxozerLqzDgK/KpbdL/k22qOLkFMT6QT+KTodQzLO9LSfP0Ee
         aSzN/YL7avbUqa1NmnHOsBAAqLn5ZQtpa8Ez0=
MIME-Version: 1.0
In-Reply-To: <4af5cd780907080423t4dbfbe1ch7db41fedbc38d551@mail.gmail.com>
References: <98c73dc40907080228g33af0c88u246d49c0c02ceed7@mail.gmail.com>
	 <4af5cd780907080423t4dbfbe1ch7db41fedbc38d551@mail.gmail.com>
Date: Wed, 8 Jul 2009 21:39:38 +0800
Message-ID: <98c73dc40907080639u7503e0acu8e37c5398ff583f0@mail.gmail.com>
Subject: Re: Can mapper use MultipleOutputs ??
From: Johnson Chen <dongogo@gmail.com>
To: common-user@hadoop.apache.org
Content-Type: multipart/alternative; boundary=001636456fd6df7bea046e31dedf

--001636456fd6df7bea046e31dedf
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit

Solved! Thank you!

2009/7/8 Stuart White <stuart.white1@gmail.com>

> Are you calling mos.close() in your Mapper's close() method?  For example:
>
> public static class Map extends MapReduceBase implements Mapper {
>
> (... all the stuff you already have ...)
>
>   @Override
>   public void close() throws IOException {
>      mos.close();
>    }
> }
>
>
>
> On Wed, Jul 8, 2009 at 4:28 AM, Johnson Chen <dongogo@gmail.com> wrote:
>
> > Hi ,
> > I want to output data from each Mapper , so I write the following code.
> >
> > public static class Map extends MapReduceBase implements Mapper {
> >            private MultipleOutputs mos ;
> >
> >             public void configure(JobConf job) {
> >                         mos = new MultipleOutputs(job);
> >             }
> >
> >            mos.getCollector("hashtable", reporter).collect( new Text(
> > output_data )  , new Text(""));
> >            ...
> > }
> >
> > I got hashtable-m-00000 ~ hahashtable-m-00009 files.
> >
> > But when I looked into these files ,  they were all empty .
> >
> > However , when I put MultipleOutputs in Reducer , it works!
> >
> >
> > Why ? Can Mapper use MultipleOutputs ?
> >
> >
> >
> >
> > --
> > Best wishes,
> > Johnson Chen
> >
>


-- 
Best wishes,
Johnson Chen

--001636456fd6df7bea046e31dedf--