2014-08-14 20:19:59,796 WARN  [org.apache.hadoop.io.compress.snappy.LoadSnappy]: Snappy native library is available
2014-08-14 20:33:46,843 WARN  [org.apache.hadoop.mapred.Task]: Parent died.  Exiting attempt_201407241322_0668_m_000055_0
2014-08-14 20:33:47,021 ERROR [cascading.flow.stream.TrapHandler]: caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: maprfs:/xxx/xxx/xxx/part-00001
    at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:127)
    at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
    at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
    at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:127)
    at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:443)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:353)
    at org.apache.hadoop.mapred.Child$4.run(Child.java:282)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:422)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1122)
    at org.apache.hadoop.mapred.Child.main(Child.java:271)
Caused by: java.lang.NullPointerException
    at com.mapr.fs.MapRFsInStream.read(MapRFsInStream.java:155)
    at java.io.DataInputStream.read(DataInputStream.java:100)
    at org.apache.hadoop.util.LineReader.readDefaultLine(LineReader.java:205)
    at org.apache.hadoop.util.LineReader.readLine(LineReader.java:169)
    at org.apache.hadoop.mapred.LineRecordReader.next(LineRecordReader.java:203)
    at org.apache.hadoop.mapred.LineRecordReader.next(LineRecordReader.java:43)
    at org.apache.hadoop.mapred.MapTask$TrackedRecordReader.moveToNext(MapTask.java:232)
    at org.apache.hadoop.mapred.MapTask$TrackedRecordReader.next(MapTask.java:217)
    at cascading.tap.hadoop.util.MeasuredRecordReader.next(MeasuredRecordReader.java:61)
    at cascading.scheme.hadoop.TextLine.sourceReadInput(TextLine.java:418)
    at cascading.scheme.hadoop.TextLine.source(TextLine.java:406)
    at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
    at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
    ... 10 more