You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by mokaful <64...@qq.com> on 2021/06/10 02:15:58 UTC

FlinkSQL ES7连接器无法使用

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/

Re: FlinkSQL ES7连接器无法使用

Posted by Leonard Xu <xb...@gmail.com>.
这是个依赖问题，你检查下你环境中是否只使用sql connector 的jar，即 flink-sql-connector-elasticsearch7， 如果不是 datastream 作业是不需要 flink-connector-elasticsearch7 这个 jar包的。如果不是这个问题，你可以分析下你作业里使用的 es 相关依赖，可以参考异常栈确定类再去确定jar包，看下是不是多加了一些无用的jar。

祝好，
Leonard
 

> 在 2021年11月22日，12:30，mispower <mi...@163.com> 写道：
> 
> 你好，咨询一下后续你这个问题是如何解决的？
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> At 2021-06-10 10:15:58, "mokaful" <64...@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/

Re:FlinkSQL ES7连接器无法使用

Posted by mispower <mi...@163.com>.
你好，咨询一下后续你这个问题是如何解决的？











At 2021-06-10 10:15:58, "mokaful" <64...@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/

Re:FlinkSQL ES7连接器无法使用

Posted by mispower <mi...@163.com>.
您好，最终该问题是如何解决的？我也遇到了这样的问题

















At 2021-06-10 10:15:58, "mokaful" <64...@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/

Re: FlinkSQL ES7连接器无法使用

Posted by Lin Li <li...@gmail.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 <64...@qq.com> 于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/
>