原来任务在flink 1.10.1 跑,是正常没问题的, 跑在1.11.1上启动就报错了,
求帮助啊
2020-08-1914:08:52,172WARN org.apache.flink.runtime.taskmanager.Task [] -
Source: KafkaTableSource(userId, catid, brandId, utp, utrp, extendFields,
requestTime) ->
SourceConversion(table=[default_catalog.default_database.user_visit_trace,
source: [KafkaTableSource(userId, catid, brandId, utp, utrp, extendFields,
requestTime)]], fields=[userId, catid, brandId, utp, utrp, extendFields,
requestTime]) -> Calc(select=[userId, catid, brandId]) ->
SinkConversionToTuple2 -> Filter -> Sink: Unnamed (2/2)
(a2e33347887d32e6ebfe7cbb9d388278) switched fromRUNNING to FAILED.
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
instantiate user function.
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:291)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:126)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:453)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:522)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
[yt-sven-core-1.11.1_v1.0.jar:?]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
[yt-sven-core-1.11.1_v1.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_45]
Causedby: java.lang.ClassCastException: cannot assign instance of
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.util.LRUMap to
field
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.DeserializerCache._cachedDeserializers
oftype java.util.concurrent.ConcurrentHashMapin instance of
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.DeserializerCache
at
java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2089)
~[?:1.8.0_45]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1261)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1999)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918)
~[?:1.8.0_45]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
~[?:1.8.0_45]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
~[?:1.8.0_45]
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:576)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:562)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:550)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:511)
~[yt-sven-core-1.11.1_v1.0.jar:?]
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:276)
~[yt-sven-core-1.11.1_v1.0.jar:?]
... 6 more
