java.lang.NullPointerException: writer cannot be null!

Google Groups | Unknown author | 8 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Kafka streams input using Avro

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

    Druid kafka avro

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

    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