Re: Flink job Deployement problem

2024-06-05 Thread Hang Ruan
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

Re: Flink job Deployement problem

2024-06-05 Thread Xiqian YU
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