Hi All, I was running HCatStore and HCatLoader in pig grunt. But encounter "ERROR 2088: Fetch failed. Couldn't retrieve result". Please help give a glance and give your suggestions. Thanks.
Test case: 1. Create table in hive: create table junit_unparted_basic(a int, b string) stored as RCFILE tblproperties('hcat.isd'='org.apache.hive.hcatalog.rcfile.RCFileInputDriver','hcat.osd'='org.apache.hive.hcatalog.rcfile.RCFileOutputDriver'); 2. copy basic.input.data file into hdfs, here is the content in file: 1 S1S 1 S2S 1 S3S 2 S1S 2 S2S 2 S3S 3 S1S 3 S2S 3 S3S 3. run Pig: pig -useHCatalog 4. grunt> A = load 'basic.input.data' as (a:int, b:chararray); 5. grunt> store A into 'junit_unparted_basic' using org.apache.hive.hcatalog.pig.HCatStorer(); 6. X = load 'junit_unparted_basic' using org.apache.hive.hcatalog.pig.HCatLoader(); 7. grunt> dump X Error Log: ================================================================================ Pig Stack Trace --------------- ERROR 2088: Fetch failed. Couldn't retrieve result org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1066: Unable to open iterator for alias X at org.apache.pig.PigServer.openIterator(PigServer.java:912) at org.apache.pig.tools.grunt.GruntParser.processDump(GruntParser.java:752) at org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:372) at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:228) at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:203) at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:66) at org.apache.pig.Main.run(Main.java:542) at org.apache.pig.Main.main(Main.java:156) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:94) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:55) at java.lang.reflect.Method.invoke(Method.java:619) at org.apache.hadoop.util.RunJar.main(RunJar.java:212) Caused by: org.apache.pig.PigException: ERROR 1002: Unable to store alias X at org.apache.pig.PigServer.storeEx(PigServer.java:1015) at org.apache.pig.PigServer.store(PigServer.java:974) at org.apache.pig.PigServer.openIterator(PigServer.java:887) ... 12 more Caused by: org.apache.pig.backend.executionengine.ExecException: ERROR 2088: Fetch failed. Couldn't retrieve result at org.apache.pig.backend.hadoop.executionengine.fetch.FetchLauncher.runPipeline(FetchLauncher.java:180) at org.apache.pig.backend.hadoop.executionengine.fetch.FetchLauncher.launchPig(FetchLauncher.java:81) at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.launchPig(HExecutionEngine.java:275) at org.apache.pig.PigServer.launchPlan(PigServer.java:1367) at org.apache.pig.PigServer.executeCompiledLogicalPlan(PigServer.java:1352) at org.apache.pig.PigServer.storeEx(PigServer.java:1011) ... 14 more ================================================================================