Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

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


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
>
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB