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 顺其自然 <71...@qq.com.INVALID> on 2022/04/14 14:44:48 UTC
flink sink ES7 报错：Invalid lambda deserialization
我的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
Re: flink sink ES7 报错：Invalid lambda deserialization
Posted by Shengkai Fang <fs...@gmail.com>.
退订的同学，请发送任意邮件到 user-zh-unsubscribe@flink.apache.org。
Best，
Shengkai
Shengkai Fang <fs...@gmail.com> 于2022年4月15日周五 17:34写道：
> 我记得这个问题常常是因为 lambda 函数的入参/出参被 shade 了，导致找不到对应的实现类了。不太理解你的意思，但是用 sql-client
> 使用 sql-jar 应该是没有问题的。建议你代码里面也换成 sql jar 先试试看。
>
> Best,
> Shengkai
>
> wangzhen <wz...@163.com> 于2022年4月15日周五 11:57写道：
>
>> 退订
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> 在 2022-04-14 22:44:48，"顺其自然" <71...@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
>>
>
Re: flink sink ES7 报错：Invalid lambda deserialization
Posted by Shengkai Fang <fs...@gmail.com>.
我记得这个问题常常是因为 lambda 函数的入参/出参被 shade 了，导致找不到对应的实现类了。不太理解你的意思，但是用 sql-client
使用 sql-jar 应该是没有问题的。建议你代码里面也换成 sql jar 先试试看。
Best,
Shengkai
wangzhen <wz...@163.com> 于2022年4月15日周五 11:57写道：
> 退订
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-04-14 22:44:48，"顺其自然" <71...@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
>
Re:flink sink ES7 报错：Invalid lambda deserialization
Posted by wangzhen <wz...@163.com>.
退订
在 2022-04-14 22:44:48，"顺其自然" <71...@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