apache.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)

Google Groups | Daniel Zohar | 2 years ago
  1. 0

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

    Google Groups | 2 years ago | Daniel Zohar
    apache.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. apache.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)

      at scala.collection.Iterator$class.foreach()
    2. Scala
      AbstractIterator.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:727)
      2. scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
      2 frames
    3. Scalding
      FlatMapFunction.operate
      1. com.twitter.scalding.FlatMapFunction.operate(Operations.scala:46)
      1 frame