我记得这个问题常常是因为 lambda 函数的入参/出参被 shade 了，导致找不到对应的实现类了。不太理解你的意思，但是用 sql-client 使用 sql-jar 应该是没有问题的。建议你代码里面也换成 sql jar 先试试看。
Best, Shengkai wangzhen <wz412...@163.com> 于2022年4月15日周五 11:57写道： > 退订 > > > > > > > > > > > > > > > > > > 在 2022-04-14 22:44:48，"顺其自然" <712677...@qq.com.INVALID> 写道： > >我的flink 1.12.1 sql clinet > 使用flink-sql-connector-elasticsearch7，代码里使用的flink-connector-elasticsearch7，然后在同一个flink上运行，报如下错误： > > > >Caused by: java.lang.reflect.InvocationTargetException > >at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > >at > > >sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > >at > > >sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > >at java.lang.reflect.Method.invoke(Method.java:498) > >at > java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:230) > >at sun.reflect.GeneratedMethodAccessor17.invoke(Unknown Source) > >at > > >sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > >at java.lang.reflect.Method.invoke(Method.java:498) > >at > java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1248) > >... 33 more > >Caused by: java.lang.IllegalArgumentException: Invalid lambda > deserialization > >at > > >org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink$Builder.$deserializeLambda$(ElasticsearchSink.java:86) > >... 42 more >
