pigServer.registerQuery("tmp = load 'pig' using
org.apache.hcatalog.pig.HCatLoader();");
pigServer.registerQuery("tmp = foreach tmp generate id;");
when I execute this，I cant get any error
but,When I execute
pigServer.registerQuery("store tmp into 'hive' using
org.apache.hcatalog.pig.HCatStorer();");
I get error like this:::
org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1066: Unable to open
iterator for alias tmp
at org.apache.pig.PigServer.openIterator(PigServer.java:880)
at org.gradle.PigHiveHCat.run(PigHiveHCat.java:68)
at org.gradle.PigHiveHCat.main(PigHiveHCat.java:28)
Caused by: java.io.IOException: Job terminated with anomalous status FAILED
at org.apache.pig.PigServer.openIterator(PigServer.java:872)
... 2 more
...........................................................................................................
pigServer.registerQuery("a = LOAD '/user/hadoop/pig.txt' ;");
pigServer.store("a", "/user/hadoop/pig1.txt");
pigServer.registerQuery("store a into '/user/hadoop/pig2.txt';");
........................................this is OK,so I think something about
Hcatalog is wrong...........................
At 2015-02-28 01:21:12, "Alan Gates" <alanfga...@gmail.com> wrote:
What error message are you getting?
Alan.
李运田
February 26, 2015 at 18:58
I want to use hcatalog in eclipse to deal with tables in hive.
but I cant store table into hive::
pigServer.registerQuery("tmp = load 'pig' using
org.apache.hcatalog.pig.HCatLoader();");
pigServer.registerQuery("tmp = foreach tmp generate id;");
pigServer.registerQuery("store tmp into 'hive' using
org.apache.hcatalog.pig.HCatStorer();");
I can store into file::
pigServer.registerQuery("a = LOAD '/user/hadoop/pig.txt' ;");
pigServer.store("a", "/user/hadoop/pig1.txt");
pigServer.registerQuery("store a into '/user/hadoop/pig2.txt';");
perhaps ,the hcatalog jars are wrong?
