flink集群上面提交提示这个报错

Open

#331 opened on Jun 15, 2020 3 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty: 4/5
Estimated time: 3-5 days
Newbie friendliness: 25/100

Issue type: Bug
Clarity: Needs clarification
Activity status: Stale
Tech stack: java, kafka, sql
Domain: backend, stream-processing

Research direction

The report only provides a Flink cluster submission stack trace for the missing KafkaConsumer010 class. Start by reading StreamConfig.java, OperatorChain.java, and FlinkUserCodeClassLoaders$ChildFirstClassLoader, then trace how the submitted JAR is loaded. Done means the reported submission can resolve the class without ClassNotFoundException.

Written by the indexing model from the issue text.

Description

org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.dtstack.flink.sql.source.kafka.KafkaConsumer010
ClassLoader info: URL ClassLoader:
file: '/tmp/blobStore-dd4fe0b4-6a39-4861-a8df-23e15edff435/job_c9083b2bd69fb054f32ec09a355bc42b/blob_p-7889a2fe7bceb057b33c276d297c5ad5f0b159d0-945f7d983ebb50b43255ffba6b539cc7' (valid JAR)
Class not resolvable through given classloader.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:236)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:104)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:267)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: com.dtstack.flink.sql.source.kafka.KafkaConsumer010
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1620)

Dominant language: Java
Stars: 2k
Forks: 913
PR merge metrics: No merged PRs in 30d

Contributor guide

No contributing guide indexed for this repository

First steps

Read the whole issue, then the project's contributing guide.
Comment on the issue to say you are picking it up — it saves two people doing the same work.
Fork the repository and make your change on a branch.
Open a pull request that references the issue number.

Similar issues

[Bug][UI] Replacing the color and name in the sidebar Open

Difficulty 2/5 1-3 hours Newbie friendliness 65/100

Netcracker/qubership-integration-platform#904 · Opened Sep 22, 2026
Remove Openjdk from `list-of-projects.properties` for IndentationCheck Open

Difficulty 1/5 Under an hour Newbie friendliness 88/100

checkstyle/test-configs#263 · Opened Sep 22, 2026
Resize volume API validation errors are not displayed in the UI Open

bug

Difficulty 1/5 Under an hour Newbie friendliness 90/100

apache/cloudstack#14222 · Opened Sep 22, 2026
[BUG]茶杯方块在取茶时会引发崩溃 Open

Difficulty 2/5 1-3 hours Newbie friendliness 88/100

KaleidoscopeMods/KaleidoscopeCookery#218 · Opened Sep 22, 2026
Cannot differ own consent and managed consents in My Consents view and detailed consent view. Open

1.0.0-alpha2 Type/Improvement

Difficulty 2/5 1-3 hours Newbie friendliness 68/100

wso2/dpdp-accelerator#272 · Opened Sep 22, 2026

More Java issues