这是个依赖问题，你检查下你环境中是否只使用sql connector 的jar，即 flink-sql-connector-elasticsearch7， 如果不是 datastream 作业是不需要 flink-connector-elasticsearch7 这个 jar包的。如果不是这个问题，你可以分析下你作业里使用的 es 相关依赖，可以参考异常栈确定类再去确定jar包，看下是不是多加了一些无用的jar。
祝好， Leonard > 在 2021年11月22日，12:30，mispower <mispo...@163.com> 写道： > > 你好，咨询一下后续你这个问题是如何解决的？ > > > > > > > > > > > > At 2021-06-10 10:15:58, "mokaful" <649713...@qq.com> 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/
