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 | 2 months ago
  1. 0

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

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