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

Aperta
#331 3 commenti 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
4/5
Tempo stimato
3-5 giorni
Idoneità per principianti
25/100
Tipo di issue
Bug
Chiarezza
Da chiarire
Stato di attività
Ferma
Stack tecnologico
java, kafka, sql
Ambito
backend, stream-processing

Direzione di ricerca

Il report fornisce solo uno stack trace della sottomissione a un cluster Flink per la classe mancante KafkaConsumer010. Inizia leggendo StreamConfig.java, OperatorChain.java e FlinkUserCodeLoaders$ChildFirstClassLoader, quindi traccia il modo in cui viene caricato il JAR inviato. Il lavoro è completato quando la sottomissione segnalata riesce a risolvere la classe senza ClassNotFoundException.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

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)

Lingua principale
Java
Stelle
2k
Fork
913
Nessuna PR unita negli ultimi 30g

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di DTStack/flinkStreamSQL

Tutte le issue di DTStack/flinkStreamSQL

Issue simili

Altre issue su Java

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.