Cannot load user class

Tue, 01 Sep 2020 23:00:58 -0700 

Hi all，
我们对kafka connector flink  
进行了扩展，flink-connector-kafka-base包中新增了类，在功能迁移到1.11.1中，但是sql-cli中测试运行时报了无法加载类的异常，1.10.1版本是ok的，是不是1.11版本对类加载做了什么改动？
求大佬解惑，谢谢

异常如下：
Caused by: org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot 
load user class: 
org.apache.flink.streaming.connectors.kafka.DelayFlatMapFunction
ClassLoader info: URL ClassLoader:
    file: 
'/var/folders/kl/qps350ws2kvb88r5knrp5flm0000gn/T/blobStore-c78573c7-5ebc-4d87-82ca-ce2647c79b6e/job_4d0e3bb67ab668416d108636ac6b8510/blob_p-a6a403094205e2501dc8790c04f2d21533c7af83-09bfececb34428dbb8e6c2d2eef9c5c7'
 (valid JAR)
Class not resolvable through given classloader.
        at 
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:288)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:471)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:393)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:155)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:453)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:522) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at java.lang.Thread.run(Thread.java:834) ~[?:?]
Caused by: java.lang.ClassNotFoundException: 
org.apache.flink.streaming.connectors.kafka.DelayFlatMapFunction
        at java.net.URLClassLoader.findClass(URLClassLoader.java:471) ~[?:?]
        at java.lang.ClassLoader.loadClass(ClassLoader.java:588) ~[?:?]
        at 
org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:61)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at java.lang.ClassLoader.loadClass(ClassLoader.java:521) ~[?:?]
        at java.lang.Class.forName0(Native Method) ~[?:?]
        at java.lang.Class.forName(Class.java:398) ~[?:?]
        at 
org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1965) ~[?:?]
        at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1851) 
~[?:?]
        at 
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2139) ~[?:?]
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668) 
~[?:?]
        at 
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2434) ~[?:?]
        at 
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2328) ~[?:?]
        at 
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166) ~[?:?]
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668) 
~[?:?]
        at 
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2434) ~[?:?]
        at 
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2328) ~[?:?]
        at 
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166) ~[?:?]
        at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668) 
~[?:?]
        at java.io.ObjectInputStream.readObject(ObjectInputStream.java:482) 
~[?:?]
        at java.io.ObjectInputStream.readObject(ObjectInputStream.java:440) 
~[?:?]
        at 
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:576)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:562)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:550)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:511)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:276)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:471)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:393)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:155)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:453)
 ~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:522) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) 
~[flink-dist_2.11-1.11.1.jar:1.11.1]
        at java.lang.Thread.run(Thread.java:834) ~[?:?]

回复