退订的同学，请发送任意邮件到 user-zh-unsubscr...@flink.apache.org。
Best， Shengkai Shengkai Fang <fskm...@gmail.com> 于2022年4月15日周五 17:34写道： > 我记得这个问题常常是因为 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 >> >
