ex

cascading.pipe.OperatorException: [317a76c8-3d04-4e1b-9ed...][sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)] operator Every failed executing buffer: ClojureBuffer[decl:'?prop*', '?timestamp*']
        at cascading.pipe.Every$EveryBufferHandler.operate(Every.java:542)
        at cascading.flow.stack.EveryBufferReducerStackElement.collect(EveryBufferReducerStackElement.java:89)
        at cascading.flow.stack.GroupReducerStackElement.operateGroup(GroupReducerStackElement.java:74)
        at cascading.flow.stack.GroupReducerStackElement.collect(GroupReducerStackElement.java:58)
        at cascading.flow.stack.FlowReducerStack.reduce(FlowReducerStack.java:169)
        at cascading.flow.FlowReducer.reduce(FlowReducer.java:75)
        at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:467)
        at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:415)
        at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:258)
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: problem advancing post rec#0
        at clojure.lang.LazySeq.sval(LazySeq.java:47)
        at clojure.lang.LazySeq.seq(LazySeq.java:56)
        at clojure.lang.RT.seq(RT.java:450)
        at cascalog.ClojureBuffer.operate(ClojureBuffer.java:36)
        at cascading.pipe.Every$EveryBufferHandler.operate(Every.java:534)
        ... 8 more
Caused by: java.lang.RuntimeException: problem advancing post rec#0
        at org.apache.hadoop.mapred.Task$ValuesIterator.next(Task.java:1077)
        at org.apache.hadoop.mapred.ReduceTask$ReduceValuesIterator.moveToNext(ReduceTask.java:245)
        at org.apache.hadoop.mapred.ReduceTask$ReduceValuesIterator.next(ReduceTask.java:241)
        at cascading.pipe.cogroup.GroupClosure$1.next(GroupClosure.java:83)
        at cascading.pipe.cogroup.GroupClosure$1.next(GroupClosure.java:73)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.initLastValues(InnerJoin.java:82)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.next(InnerJoin.java:114)
        at cascading.pipe.cogroup.InnerJoin$JoinIterator.next(InnerJoin.java:48)
        at cascading.tuple.TupleEntryIterator.next(TupleEntryIterator.java:101)
        at cascading.pipe.Every$EveryBufferHandler$2.next(Every.java:523)
        at cascading.pipe.Every$EveryBufferHandler$2.next(Every.java:510)
        at cascalog.TupleSeqConverter.next(TupleSeqConverter.java:20)
        at cascalog.TupleSeqConverter.next(TupleSeqConverter.java:8)
        at clojure.lang.IteratorSeq.first(IteratorSeq.java:50)
        at clojure.lang.RT.first(RT.java:539)
        at clojure.core$first.invoke(core.clj:53)
        at clojure.core$take$fn__3724.invoke(core.clj:2160)
        at clojure.lang.LazySeq.sval(LazySeq.java:42)
        ... 12 more
Caused by: java.io.EOFException
        at java.io.DataInputStream.readByte(DataInputStream.java:267)
        at org.apache.hadoop.io.WritableUtils.readVLong(WritableUtils.java:299)
        at org.apache.hadoop.io.WritableUtils.readVInt(WritableUtils.java:320)
        at cascading.tuple.TupleInputStream.readVInt(TupleInputStream.java:139)
        at cascading.tuple.TupleInputStream.readToken(TupleInputStream.java:96)
        at cascading.tuple.TupleInputStream.getNextElement(TupleInputStream.java:101)
        at cascading.tuple.TupleInputStream.readTuple(TupleInputStream.java:84)
        at cascading.tuple.TupleInputStream.readTuple(TupleInputStream.java:73)
        at cascading.tuple.hadoop.TupleDeserializer.deserialize(TupleDeserializer.java:38)
        at cascading.tuple.hadoop.TupleDeserializer.deserialize(TupleDeserializer.java:28)
        at org.apache.hadoop.mapred.Task$ValuesIterator.readNextValue(Task.java:1134)
        at org.apache.hadoop.mapred.Task$ValuesIterator.next(Task.java:1074)
        ... 29 more