Hi,
I added my custom jar (that includes dependencies on Jackson) to Flink
classpath. It seems to be loaded just fine. But when the job starts I am
getting an exception below. I am sure how to interpret the exception though
and would appreciate it if somebody gives me advice on it.
Thanks
Alex
2020-11-20 18:34:35,643 WARN org.apache.flink.runtime.taskmanager.Task [] -
Source: Custom Source -> Flat Map -> Flat Map -> Sink: Unnamed (1/1)
(dcbf799dadba5d4b7e7f5af15919a4b6) switched from RUNNING to FAILED.
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig
.getStreamOperatorFactory(StreamConfig.java:275) ~[flink-dist_2.11-1.11.2
.jar:1.11.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain
.createChainedOperator(OperatorChain.java:471) ~[flink-dist_2.11-1.11.2.jar:
1.11.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain
.createOutputCollector(OperatorChain.java:393) ~[flink-dist_2.11-1.11.2.jar:
1.11.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(
OperatorChain.java:155) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(
StreamTask.java:459) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask
.java:528) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
[flink-dist_2.11-1.11.2.jar:1.11.2]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_265]
Caused by: java.lang.ClassCastException: cannot assign instance of
java.util.concurrent.ConcurrentHashMap to field
com.fasterxml.jackson.databind.deser.DeserializerCache._cachedDeserializers
of type com.fasterxml.jackson.databind.util.LRUMap in instance of
com.fasterxml.jackson.databind.deser.DeserializerCache
at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(
ObjectStreamClass.java:2301) ~[?:1.8.0_265]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:
1431) ~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2372) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:
2366) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2290)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:
2148) ~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1647)
~[?:1.8.0_265]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:483) ~[?:
1.8.0_265]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:441) ~[?:
1.8.0_265]
at org.apache.flink.util.InstantiationUtil.deserializeObject(
InstantiationUtil.java:576) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(
InstantiationUtil.java:562) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(
InstantiationUtil.java:550) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(
InstantiationUtil.java:511) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at org.apache.flink.streaming.api.graph.StreamConfig
.getStreamOperatorFactory(StreamConfig.java:260) ~[flink-dist_2.11-1.11.2
.jar:1.11.2]
... 8 more
