to be serialized). There are no lambda functions in the output object
>> (it is just a string object).
>>
>> Thanks,
>> Tom
>>
>> On Thu, May 26, 2022 at 9:36 PM yuxia
>> wrote:
>>
>>> It seems an exception thrown when Flink try to deserialize
On Thu, May 26, 2022 at 9:36 PM yuxia wrote:
>
>> It seems an exception thrown when Flink try to deserialize the object
>> outputed by your udf. So is the obejct produced by your udf serializable?
>> Does it contain any lambda function in the object/class?
>>
>> B
lambda function in the object/class?
>
> Best regards,
> Yuxia
>
> --
> *发件人: *"Tom Thornton"
> *收件人: *"User"
> *发送时间: *星期五, 2022年 5 月 27日 上午 6:47:04
> *主题: *Exception when running Java UDF with Blink table planner
>
>
Hi,
Thank you for your help. Here's the requested info:
Could you also tell us which Flink version you are using, the schema of the
> source table and some test data? With these info, we can debug in our local
> environment.
>
Flink version: 1.11.6.
Schema of the source table:
name | type | null
022年 5 月 27日 上午 6:47:04
主题: Exception when running Java UDF with Blink table planner
We are migrating from the legacy table planner to the Blink table planner.
Previously we had a UDF defined like this that worked without issue:
public class ListToString extends DPScalarFunction {
public St
Hi.
Could you also tell us which Flink version you are using, the schema of the
source table and some test data? With these info, we can debug in our local
environment.
Best,
Shengkai
Tom Thornton 于2022年5月27日周五 06:47写道：
> We are migrating from the legacy table planner to the Blink table planne
We are migrating from the legacy table planner to the Blink table planner.
Previously we had a UDF defined like this that worked without issue:
public class ListToString extends DPScalarFunction {
public String eval(List list) {
return "foo";
}
Since moving to the Blink table plan
