Forgot to say, value "0" means that the requested counter does not exist.
2009/2/5 Rasit OZDAS <rasitoz...@gmail.com>:
> Sharath,
> I think the static enum definition should be out of Reduce class.
> Hadoop probably tries to find it elsewhere with "MyCounter", but it's
> actually "Reduce.MyCounter" in your example.
>
> Hope this helps,
> Rasit
>
> 2009/2/5 some speed <speed.s...@gmail.com>:
>> I Tried the following...It gets compiled but the value of result seems to be
>> 0 always.
>>
>> RunningJob running = JobClient.runJob(conf);
>>
>> Counters ct = new Counters();
>> ct = running.getCounters();
>>
>> long result =
>> ct.findCounter("org.apache.hadoop.mapred.Task$Counter", 0,
>> "*MyCounter*").getCounter();
>> //even tried MyCounter.Key1
>>
>>
>>
>> Does anyone know whay that is happening?
>>
>> Thanks,
>>
>> Sharath
>>
>>
>>
>> On Thu, Feb 5, 2009 at 5:59 AM, some speed <speed.s...@gmail.com> wrote:
>>
>>> Hi Tom,
>>>
>>> I get the error :
>>>
>>> Cannot find Symbol* "**MyCounter.ct_key1 " *
>>>
>>>
>>>
>>>
>>>
>>>
>>> On Thu, Feb 5, 2009 at 5:51 AM, Tom White <t...@cloudera.com> wrote:
>>>
>>>> Hi Sharath,
>>>>
>>>> The code you posted looks right to me. Counters#getCounter() will
>>>> return the counter's value. What error are you getting?
>>>>
>>>> Tom
>>>>
>>>> On Thu, Feb 5, 2009 at 10:09 AM, some speed <speed.s...@gmail.com> wrote:
>>>> > Hi,
>>>> >
>>>> > Can someone help me with the usage of counters please? I am incrementing
>>>> a
>>>> > counter in Reduce method but I am unable to collect the counter value
>>>> after
>>>> > the job is completed.
>>>> >
>>>> > Its something like this:
>>>> >
>>>> > public static class Reduce extends MapReduceBase implements
>>>> Reducer<Text,
>>>> > FloatWritable, Text, FloatWritable>
>>>> > {
>>>> > static enum MyCounter{ct_key1};
>>>> >
>>>> > public void reduce(..............) throws IOException
>>>> > {
>>>> >
>>>> > reporter.incrCounter(MyCounter.ct_key1, 1);
>>>> >
>>>> > output.collect(......);
>>>> >
>>>> > }
>>>> > }
>>>> >
>>>> > -----main method----
>>>> > {
>>>> > RunningJob running = null;
>>>> > running=JobClient.runJob(conf);
>>>> >
>>>> > Counters ct = running.getCounters();
>>>> > /********* How do I Collect the ct_key1 value ????***********/
>>>> > long res = ct.getCounter(MyCounter.ct_key1);
>>>> >
>>>> > }
>>>> >
>>>> >
>>>> >
>>>> >
>>>> >
>>>> > Thanks,
>>>> >
>>>> > Sharath
>>>> >
>>>>
>>>
>>>
>>
>
>
>
> --
> M. Raşit ÖZDAŞ
>
--
M. Raşit ÖZDAŞ
