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/ |
你好,
从异常栈看,建议可以排查下提交环境的 es7 connector jar 和 运行时使用的版本是否不一致? 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 mokaful <[hidden email]> 于2021年6月10日周四 上午10:16写道: > 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/ > |
Free forum by Nabble | Edit this page |