Hi Guys,
 I am facing a wiered issue.
 I refered similar issue of DiskErrorException in the mail archives :
http://mail-archives.apache.org/mod_mbox/pig-user/201106.mbox/%[email protected]%3E

But looks like there it was a real problem with disk space.

when I do df -kh I see that there is enough space on the node.


Filesystem                                        Size  Used Avail Use%
Mounted on
/dev/mapper/volgrp0rootVol00          7.7G  4.6G  2.8G  63% /
tmpfs                                                 939M     0  939M   0%
/dev/shm
/dev/sda1                                          194M  132M   53M  72%
/boot
/dev/mapper/volgrouphadoop-l         491G  198M  466G   1% /mnt/data


We are using pig 0.11.1
I do not see this issue on other nodes.

I am pasting the stacktrace for reference.

org.apache.pig.tools.grunt.GruntParser - ERROR 2997: Unable to recreate
exception from backed error: java.io.IOException: Spill failed
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer$Buffer.write(MapTask.java:1213)
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer$Buffer.write(MapTask.java:1194)
        at java.io.DataOutputStream.writeBoolean(DataOutputStream.java:139)
        at
org.apache.pig.impl.io.PigNullableWritable.write(PigNullableWritable.java:122)
        at
org.apache.hadoop.io.serializer.WritableSerialization$WritableSerializer.serialize(WritableSerialization.java:90)
        at
org.apache.hadoop.io.serializer.WritableSerialization$WritableSerializer.serialize(WritableSerialization.java:77)
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer.collect(MapTask.java:1061)
        at
org.apache.hadoop.mapred.MapTask$NewOutputCollector.write(MapTask.java:691)
        at
org.apache.hadoop.mapreduce.TaskInputOutputContext.write(TaskInputOutputContext.java:80)
        at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Map.collect(PigGenericMapReduce.java:123)
        at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.runPipeline(PigGenericMapBase.java:285)
        at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:278)
        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:764)
        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)
        at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
        at java.security.AccessController.doPrivileged(Native Method)
        at javax.security.auth.Subject.doAs(Subject.java:415)
        at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1149)
        at org.apache.hadoop.mapred.Child.main(Child.java:249)
Caused by: org.apache.hadoop.util.DiskChecker$DiskErrorException: Could not
find any valid local directory for output/spill11.out
        at
org.apache.hadoop.fs.LocalDirAllocator$AllocatorPerContext.getLocalPathForWrite(LocalDirAllocator.java:381)
        at
org.apache.hadoop.fs.LocalDirAllocator.getLocalPathForWrite(LocalDirAllocator.java:146)
        at
org.apache.hadoop.fs.LocalDirAllocator.getLocalPathForWrite(LocalDirAllocator.java:127)
        at
org.apache.hadoop.mapred.MapOutputFile.getSpillFileForWrite(MapOutputFile.java:121)
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer.sortAndSpill(MapTask.java:1392)
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer.access$1800(MapTask.java:853)
        at
org.apache.hadoop.mapred.MapTask$MapOutputBuffer$SpillThread.run(MapTask.java:1344)

Is it an iussue due to configuration ?
Any help on this issue will be helpful.

Thanks in advance.
Regards,
Darpan

Reply via email to