バグ #592
ERROR Error handling message; exiting java.lang.Exception: class jp.ihearts.XGenerationAggregation.AccessLog requires value for 'referer'
ステータス: | 新規 | 開始日: | 2015/11/28 | |
---|---|---|---|---|
優先度: | 急いで | 期日: | ||
担当者: | 山本 義治 | 進捗 %: | 0% | |
カテゴリ: | ログ集計 | 作業時間の記録: | - | |
対象バージョン: | - |
説明
AppRealtimeLog(2015-11-28T03:42:56.000Z,halooandroid,,0,0,0,2,1,1,0.0,0.0)
ERROR Error handling message; exiting
java.lang.Exception: class jp.ihearts.XGenerationAggregation.AccessLog requires value for 'referer'
at com.novus.salat.DefaultArg.safeValue$lzycompute(Grater.scala:462)
at com.novus.salat.DefaultArg.safeValue(Grater.scala:458)
at com.novus.salat.ConcreteGrater.safeDefault(Grater.scala:419)
at com.novus.salat.ConcreteGrater$$anonfun$8$$anonfun$apply$5.apply(Grater.scala:377)
at com.novus.salat.ConcreteGrater$$anonfun$8$$anonfun$apply$5.apply(Grater.scala:377)
at scala.Option.orElse(Option.scala:257)
at com.novus.salat.ConcreteGrater$$anonfun$8.apply(Grater.scala:377)
at com.novus.salat.ConcreteGrater$$anonfun$8.apply(Grater.scala:360)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.immutable.List.foreach(List.scala:318)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at com.novus.salat.ConcreteGrater.fromJSON(Grater.scala:360)
at com.novus.salat.Grater.fromJSON(Grater.scala:73)
at jp.ihearts.XGenerationAggregation.AccessLogDecoder.fromBytes(Codec.scala:12)
at jp.ihearts.XGenerationAggregation.AccessLogDecoder.fromBytes(Codec.scala:10)
at kafka.message.MessageAndMetadata.message(MessageAndMetadata.scala:32)
at org.apache.spark.streaming.kafka.KafkaReceiver$MessageHandler$$anonfun$run$2.apply(KafkaInputDStream.scala:135)
at org.apache.spark.streaming.kafka.KafkaReceiver$MessageHandler$$anonfun$run$2.apply(KafkaInputDStream.scala:134)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:25)
at org.apache.spark.streaming.kafka.KafkaReceiver$MessageHandler.run(KafkaInputDStream.scala:134)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:701)
履歴
#2 山本 義治 が約9年前に更新
exception handling case in map() method
http://stackoverflow.com/questions/30343588/spark-how-to-handle-error-case-in-rdd-map-method-correctly