org.apache.flink.runtime.client.JobExecutionException: Job execution failed.

flink-user | Madhukar Thota | 1 year ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Re: Kafka + confluent schema registry Avro parsing

    flink-user | 1 year ago | Madhukar Thota
    java.lang.Exception

    Root Cause Analysis

    1. java.lang.NullPointerException

      No message provided

      at test.flink.MyAvroDeserializer.deserialize()
    2. test.flink
      MyAvroDeserializer.deserialize
      1. test.flink.MyAvroDeserializer.deserialize(MyAvroDeserializer.java:23)
      2. test.flink.MyAvroDeserializer.deserialize(MyAvroDeserializer.java:11)
      2 frames
    3. org.apache.flink
      LegacyFetcher$SimpleConsumerThread.run
      1. org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher$SimpleConsumerThread.run(LegacyFetcher.java:445)
      1 frame