AnsweredAssumed Answered

Exception in Cascading after upgrade to MapR 2.1

Question asked by jerdavis on Mar 18, 2013
Latest reply on Mar 18, 2013 by jerdavis
Hello,
After upgrading MapR from 1.2.9 to 2.1.2 I've started to get the following exception.
I'm using Cascading 2.1.5
java version "1.6.0_24"
Java(TM) SE Runtime Environment (build 1.6.0_24-b07)
Java HotSpot(TM) 64-Bit Server VM (build 19.1-b02, mixed mode)

I will try to put together a unit test, but in the mean time I wonder if anyone has seen this exception?

<pre>
cascading.tuple.TupleException: unable to sink into output identifier: /general/K12001/modelset/failure/201303181409/DataSetJoiner
at cascading.tuple.TupleEntrySchemeCollector.collect(TupleEntrySchemeCollector.java:160)
at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:93)
at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:71)
at cascading.tuple.TupleEntrySchemeCollector.add(TupleEntrySchemeCollector.java:134)
at cascading.flow.stream.TrapHandler.handleException(TrapHandler.java:131)
at cascading.flow.stream.TrapHandler.handleException(TrapHandler.java:115)
at cascading.flow.stream.ElementStage.handleException(ElementStage.java:134)
at cascading.flow.stream.BufferEveryWindow.receive(BufferEveryWindow.java:151)
at cascading.flow.stream.BufferEveryWindow.receive(BufferEveryWindow.java:41)
at cascading.flow.hadoop.stream.HadoopGroupGate.run(HadoopGroupGate.java:90)
at cascading.flow.hadoop.FlowReducer.reduce(FlowReducer.java:133)
at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:499)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:447)
at org.apache.hadoop.mapred.Child$4.run(Child.java:270)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1127)
at org.apache.hadoop.mapred.Child.main(Child.java:264)
Caused by: java.util.NoSuchElementException
at java.util.AbstractList$Itr.next(AbstractList.java:350)
at cascading.scheme.util.DelimitedParser.joinNoQuote(DelimitedParser.java:386)
at cascading.scheme.util.DelimitedParser.joinLine(DelimitedParser.java:346)
at cascading.scheme.hadoop.TextDelimited.write(TextDelimited.java:900)
at cascading.scheme.hadoop.TextDelimited.sink(TextDelimited.java:891)
at cascading.tuple.TupleEntrySchemeCollector.collect(TupleEntrySchemeCollector.java:153)
... 17 more

Outcomes