java.lang.NullPointerException: writer cannot be null!

Google Groups | Unknown author | 5 months ago
  1. 0

    Kafka streams input using Avro

    Google Groups | 5 months ago | Unknown author
    java.lang.NullPointerException: writer cannot be null!
  2. 0

    Druid kafka avro

    Google Groups | 4 months ago | Younes
    java.lang.NullPointerException: writer cannot be null!
  3. 0

    Druid kafka avro

    Google Groups | 4 months ago | Younes
    java.lang.NullPointerException: writer cannot be null!
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Druid avro extension resulting in UnsupportedOperationException from Tranquility

    Google Groups | 5 months ago | Ben Vogan
    java.lang.NullPointerException: writer cannot be null!
  6. 0

    Kafka streams input using Avro

    Google Groups | 5 months ago | Unknown author
    java.lang.NullPointerException: writer cannot be null!

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.NullPointerException

      writer cannot be null!

      at org.apache.avro.io.ResolvingDecoder.resolve()
    2. Apache Avro
      GenericDatumReader.read
      1. org.apache.avro.io.ResolvingDecoder.resolve(ResolvingDecoder.java:80)[na:na]
      2. org.apache.avro.io.ResolvingDecoder.<init>(ResolvingDecoder.java:49)[na:na]
      3. org.apache.avro.io.DecoderFactory.resolvingDecoder(DecoderFactory.java:307)[na:na]
      4. org.apache.avro.generic.GenericDatumReader.getResolver(GenericDatumReader.java:125)[na:na]
      5. org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:140)[na:na]
      5 frames
    3. io.druid.data
      SchemaRepoBasedAvroBytesDecoder.parse
      1. io.druid.data.input.avro.SchemaRepoBasedAvroBytesDecoder.parse(SchemaRepoBasedAvroBytesDecoder.java:82)[na:na]
      1 frame
    4. Druid Processing
      AvroStreamInputRowParser.parse
      1. io.druid.data.input.AvroStreamInputRowParser.parse(AvroStreamInputRowParser.java:53)[na:na]
      2. io.druid.data.input.AvroStreamInputRowParser.parse(AvroStreamInputRowParser.java:33)[na:na]
      2 frames
    5. com.metamx.tranquility
      TransformingBeam$$anonfun$sendAll$2$$anonfun$2.apply
      1. com.metamx.tranquility.druid.DruidBeams$$anonfun$1$$anonfun$7.apply(DruidBeams.scala:177)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      2. com.metamx.tranquility.druid.DruidBeams$$anonfun$1$$anonfun$7.apply(DruidBeams.scala:177)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      3. com.metamx.tranquility.druid.DruidBeams$$anonfun$1$$anonfun$apply$1.apply(DruidBeams.scala:195)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      4. com.metamx.tranquility.druid.DruidBeams$$anonfun$1$$anonfun$apply$1.apply(DruidBeams.scala:195)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      5. com.metamx.tranquility.beam.TransformingBeam$$anonfun$sendAll$2$$anonfun$2.apply(TransformingBeam.scala:36)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      5 frames
    6. util-core
      Try$.apply
      1. com.twitter.util.Try$.apply(Try.scala:13)[com.twitter.util-core_2.11-6.30.0.jar:6.30.0]
      1 frame
    7. com.metamx.tranquility
      TransformingBeam$$anonfun$sendAll$2.apply
      1. com.metamx.tranquility.beam.TransformingBeam$$anonfun$sendAll$2.apply(TransformingBeam.scala:36)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      2. com.metamx.tranquility.beam.TransformingBeam$$anonfun$sendAll$2.apply(TransformingBeam.scala:35)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      2 frames
    8. Scala
      TraversableLike$WithFilter.foreach
      1. scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:778)[org.scala-lang.scala-library-2.11.7.jar:na]
      2. scala.collection.Iterator$class.foreach(Iterator.scala:742)[org.scala-lang.scala-library-2.11.7.jar:na]
      3. scala.collection.AbstractIterator.foreach(Iterator.scala:1194)[org.scala-lang.scala-library-2.11.7.jar:na]
      4. scala.collection.IterableLike$class.foreach(IterableLike.scala:72)[org.scala-lang.scala-library-2.11.7.jar:na]
      5. scala.collection.AbstractIterable.foreach(Iterable.scala:54)[org.scala-lang.scala-library-2.11.7.jar:na]
      6. scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:777)[org.scala-lang.scala-library-2.11.7.jar:na]
      6 frames
    9. com.metamx.tranquility
      Tranquilizer$$anonfun$send$1.apply
      1. com.metamx.tranquility.beam.TransformingBeam.sendAll(TransformingBeam.scala:35)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      2. com.metamx.tranquility.tranquilizer.Tranquilizer.com$metamx$tranquility$tranquilizer$Tranquilizer$$sendBuffer(Tranquilizer.scala:301)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      3. com.metamx.tranquility.tranquilizer.Tranquilizer$$anonfun$send$1.apply(Tranquilizer.scala:202)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      4. com.metamx.tranquility.tranquilizer.Tranquilizer$$anonfun$send$1.apply(Tranquilizer.scala:202)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      4 frames
    10. Scala
      Option.foreach
      1. scala.Option.foreach(Option.scala:257)[org.scala-lang.scala-library-2.11.7.jar:na]
      1 frame
    11. com.metamx.tranquility
      KafkaConsumer$2.run
      1. com.metamx.tranquility.tranquilizer.Tranquilizer.send(Tranquilizer.scala:202)[io.druid.tranquility-core-0.8.0.jar:0.8.0]
      2. com.metamx.tranquility.kafka.writer.TranquilityEventWriter.send(TranquilityEventWriter.java:76)[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]
      3. com.metamx.tranquility.kafka.KafkaConsumer$2.run(KafkaConsumer.java:231)[io.druid.tranquility-kafka-0.8.0.jar:0.8.0]
      3 frames
    12. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)[na:1.7.0_101]
      2. java.util.concurrent.FutureTask.run(FutureTask.java:262)[na:1.7.0_101]
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[na:1.7.0_101]
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[na:1.7.0_101]
      5. java.lang.Thread.run(Thread.java:745)[na:1.7.0_101]
      5 frames