flink1.11.1 SQL任务启动报错

[hb]

原来任务在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