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 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