【flink】flink Class not resolvable through given classloader ClassNotFoundException: FlinkKafkaConsum

在这里插入图片描述

1.概述

某些情况下 flink报错如下

2021-04-16 17:13:52
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
ClassLoader info: URL ClassLoader:
    file: '/tmp/blobStore-4a12d9a9-d183-4ef7-9aff-472f4256835f/job_7b5ea83cada0b03c240b3057826bb433/blob_p-eabf998767a61c662fc9d50b63b543e96dae63e5-3a9c6e542ff9dacac8595deaf52a24ab' (valid JAR)
Class not resolvable through given classloader.
  at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory

相关文章

Flink-core小总结1.实时计算和离线计算1.1离线计算离线计算的...
2022年7月26日,Taier1.2版本正式发布!本次版本发布更新功能...
关于Flink相关的概念性东西就不说了,网上都有,官网也很详尽...
最近准备用flink对之前项目进行重构,这是一个有挑战(但我很...
Thispostoriginallyappearedonthe ApacheFlinkblog.Itwasre...
Flink配置文件对于管理员来说,差不多经常调整的就只有conf下...