A = (a, b, c)
 I just want add a column 0 into A, and the A will be like this:

A = (a, b, c, 0)

How can I?

I use cross, but when I use PARALLEL BIGGER(>=300), it occurs that:

ERROR org.apache.pig.tools.grunt.GruntParser  - java.io.IOException: Unable to 
store alias null
        at 
org.apache.pig.impl.util.WrappedIOException.wrap(WrappedIOException.java:34)
        at org.apache.pig.PigServer.registerQuery(PigServer.java:296)
        at 
org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:475)
        at 
org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:233)
        at 
org.apache.pig.tools.grunt.GruntParser.parseContOnError(GruntParser.java:91)
        at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:54)
        at org.apache.pig.Main.main(Main.java:270)
Caused by: org.apache.pig.backend.executionengine.ExecException: 
java.io.IOException: Job failed
        at 
org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.execute(HExecutionEngine.java:296)
        at org.apache.pig.PigServer.optimizeAndRunQuery(PigServer.java:413)
        at org.apache.pig.PigServer.registerQuery(PigServer.java:293)
        ... 5 more
Caused by: java.io.IOException: Job failed
        at 
org.apache.pig.backend.hadoop.executionengine.POMapreduce.open(POMapreduce.java:188)
        at 
org.apache.pig.backend.hadoop.executionengine.POMapreduce.open(POMapreduce.java:178)
        at 
org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.execute(HExecutionEngine.java:282)
        ... 7 more

99316 [main] ERROR org.apache.pig.tools.grunt.GruntParser  - 
java.io.IOException: Unable to store alias null


The Hadoop is 0.18 release, and I use the patch 
https://issues.apache.org/jira/browse/PIG-253

and I set Parallel 100, it can run OK. Why? I think it opens too many fd, but I 
have set it 10240.

So 1: how can I get my A?
   2: Why error?

 
 
 

Reply via email to