你好，咨询一下后续你这个问题是如何解决的？
At 2021-06-10 10:15:58, "mokaful" <[email protected]> wrote: >org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot >instantiate user function. > at >org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:338) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:653) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:626) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:616) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:616) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:616) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:181) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:548) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181] >Caused by: java.io.InvalidClassException: >org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch7DynamicSink$AuthRestClientFactory; >local class incompatible: stream classdesc serialVersionUID = >-2564582543942331131, local class serialVersionUID = -2353232579685349916 > at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:699) >~[?:1.8.0_181] > at > java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1885) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751) >~[?:1.8.0_181] > at >java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) >~[?:1.8.0_181] > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) >~[?:1.8.0_181] > at >java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) >~[?:1.8.0_181] > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) >~[?:1.8.0_181] > at >java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) >~[?:1.8.0_181] > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) >~[?:1.8.0_181] > at >java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) >~[?:1.8.0_181] > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) >~[?:1.8.0_181] > at >java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) >~[?:1.8.0_181] > at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) >~[?:1.8.0_181] > at >org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:615) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:600) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:587) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:541) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > at >org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:322) >~[flink-dist_2.11-1.13.1.jar:1.13.1] > > > >-- >Sent from: http://apache-flink.147419.n8.nabble.com/
