Cascalog 2.0 stack trace

gistfile1.txt

cascading.pipe.OperatorException: [d9b750b1-28f6-4c53-a32...][cascading.pipe.assembly.AggregateBy.initialize(AggregateBy.java:564)] operator Each failed executing operation
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:107)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:73)
	at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:34)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at com.idexx.lambda.hadoop.jobs.assembler.EntityAssembler$ExtractFields.operate(EntityAssembler.java:121)
	at cascalog.CascalogFunctionExecutor.operate(CascalogFunctionExecutor.java:41)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:73)
	at cascading.flow.stream.FilterEachStage.receive(FilterEachStage.java:34)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:119)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:107)
	at cascading.operation.Identity$2.operate(Identity.java:137)
	at cascading.operation.Identity.operate(Identity.java:150)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	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:418)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:349)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:211)
Caused by: clojure.lang.ArityException: Wrong number of args (3) passed to: platform$eval4722$fn
	at clojure.lang.AFn.throwArity(AFn.java:437)
	at clojure.lang.AFn.invoke(AFn.java:47)
	at clojure.lang.AFn.applyToHelper(AFn.java:167)
	at clojure.lang.AFn.applyTo(AFn.java:151)
	at clojure.lang.AFunction$1.doInvoke(AFunction.java:29)
	at clojure.lang.RestFn.applyTo(RestFn.java:137)
	at cascalog.aggregator.ClojureMonoidFunctor.applyPrepareFn(ClojureMonoidFunctor.java:35)
	at cascalog.aggregator.ClojureMonoidFunctor.prepare(ClojureMonoidFunctor.java:29)
	at cascalog.aggregator.ClojureMonoidFunctor.prepare(ClojureMonoidFunctor.java:11)
	at cascalog.aggregator.FoldFunctor.aggregate(FoldFunctor.java:34)
	at cascading.pipe.assembly.AggregateBy$CompositeFunction.operate(AggregateBy.java:344)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	... 25 more