Hi, Fokou Toukam.
This error occurs when the schema in the sink mismatches the schema you
provided from the upstream.
You may need to check whether the provided type of field `features` in sink
is the same as the type in the provided upstream.
Best,
Hang
Fokou Toukam, Thierry 于2024年6月6日周四
10:22
Hi Fokou,
Seems `features` column was inferenced to be RAW type, which doesn’t carry any
specific data information, and causes following type casting failed.
Sometimes it will happen when Flink can’t infer return type from a lambda
expression but no explicit returning type information was provi