hadoop.mapred.TaskAttemptListenerImpl: Diagnostics report from attempt_1433489536106_0003_m_000010_0: Error: cascading.pipe. OperatorException: [com.snowplowanalytics....][com.twitter.scalding. RichPipe.each(RichPipe.scala:471)] 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.FunctionEachStage$1.collect(FunctionEachStage. java:80) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector. java:145)

Google Groups | Daniel Zohar | 1 year ago
  1. 0

    EMR ETL Runner: java.lang.IllegalStateException: Joda-time 2.2 or later version is required, but found version: null

    Google Groups | 1 year ago | Daniel Zohar
    hadoop.mapred.TaskAttemptListenerImpl: Diagnostics report from attempt_1433489536106_0003_m_000010_0: Error: cascading.pipe. OperatorException: [com.snowplowanalytics....][com.twitter.scalding. RichPipe.each(RichPipe.scala:471)] 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.FunctionEachStage$1.collect(FunctionEachStage. java:80) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector. java:145)
  2. 0

    EMR ETL Runner: java.lang.IllegalStateException: Joda-time 2.2 or later version is required, but found version: null

    Google Groups | 1 year ago | Daniel Zohar
    hadoop.mapred.TaskAttemptListenerImpl: Diagnostics report from attempt_1433489536106_0003_m_000010_0: Error: cascading.pipe. OperatorException: [com.snowplowanalytics....][com.twitter.scalding. RichPipe.each(RichPipe.scala:471)] 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.FunctionEachStage$1.collect(FunctionEachStage. java:80) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector. java:145) at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133 ) at com.twitter.scalding.FlatMapFunction$$anonfun$operate$2.apply( Operations.scala:48) at com.twitter.scalding.FlatMapFunction$$anonfun$operate$2.apply( Operations.scala:46)

    Root Cause Analysis

    1. hadoop.mapred.TaskAttemptListenerImpl

      Diagnostics report from attempt_1433489536106_0003_m_000010_0: Error: cascading.pipe. OperatorException: [com.snowplowanalytics....][com.twitter.scalding. RichPipe.each(RichPipe.scala:471)] 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.FunctionEachStage$1.collect(FunctionEachStage. java:80) at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector. java:145)

      at cascading.tuple.TupleEntryCollector.add()
    2. cascading.tuple
      TupleEntryCollector.add
      1. cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
      1 frame