Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Pig >> mail # user >> error when using CurrentTime()


+
Danfeng Li 2013-02-15, 23:21
+
Cheolsoo Park 2013-02-18, 02:50
Copy link to this message
-
RE: error when using CurrentTime()
Hi, Cheolsoo,

Sorry for the late reply. I figured it out it's due to my environmental variables are still point to the old version of pig. Thanks for looking into this.

I do have another question about the CurrentTime(), I'll post it in another email.

Dan

-----Original Message-----
From: Cheolsoo Park [mailto:[EMAIL PROTECTED]]
Sent: Sunday, February 17, 2013 6:51 PM
To: [EMAIL PROTECTED]
Subject: Re: error when using CurrentTime()

Hi Dan,

I tried both trunk and branch-0.11, but I couldn't reproduce it. . How are you running your queries?

Thanks,
Cheolsoo

On Fri, Feb 15, 2013 at 3:21 PM, Danfeng Li <[EMAIL PROTECTED]> wrote:

> I got the following error when using the new built in function
> CurrentTime()
>
> 2013-02-15 14:42:37,228 [main] ERROR org.apache.pig.tools.grunt.Grunt
> - ERROR 2997: Unable to recreate exception from backed error:
> org.apache.pig.backend.executionengine.ExecException: ERROR 2080:
> Foreach currently does not handle type Unknown
>                 at
> org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.processPlan(POForEach.java:337)
>                 at
> org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:284)
>                 at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.runPipeline(PigGenericMapBase.java:271)
>                 at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:266)
>                 at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:64)
>                 at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
>                 at
> org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:647)
>                 at org.apache.hadoop.mapred.MapTask.run(MapTask.java:323)
>                 at org.apache.hadoop.mapred.Child$4.run(Child.java:270)
>                 at java.security.AccessController.doPrivileged(Native
> Method)
>                 at
>
> Here's my code:
>
> A = load 'test.txt' as (a:chararray);
> dump A;
> B = foreach A generate *, CurrentTime(); dump B;
>
> Any idea?
>
> Thanks.
> Dan
>
>