org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 ClassLoader info: URL ClassLoader: Class not resolvable through given classloader.

Stack Overflow | john | 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

    Classloader issues with Kafka Connector and Remote Executor (Apache Flink)

    Stack Overflow | 8 months ago | john
    org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 ClassLoader info: URL ClassLoader: Class not resolvable through given classloader.

    Root Cause Analysis

    1. org.apache.flink.streaming.runtime.tasks.StreamTaskException

      Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 ClassLoader info: URL ClassLoader: Class not resolvable through given classloader.

      at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator()
    2. org.apache.flink
      StreamTask.invoke
      1. org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:207)
      2. org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:223)
      2 frames
    3. flink-runtime
      Task.run
      1. org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
      1 frame
    4. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame