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 provided[1], and could be solved by inserting an extraneous .returns(<SomeTypeInformation>) call.[2] If that doesn’t solve your problem, could you please share more information like a code snippet or a minimum POC? Regards, yux [1] https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/java_lambdas/ [2] https://stackoverflow.com/questions/70295970/flink-table-get-type-information De : Fokou Toukam, Thierry <thierry.fokou-touka...@ens.etsmtl.ca> Date : jeudi, 6 juin 2024 à 09:04 À : user <user@flink.apache.org> Objet : Flink job Deployement problem Hi, i'm trying to deploy flink job but i have this error. How to solve it please? [cid:b13357ec-00b9-4a15-8d04-1c797a4eced3] Thierry FOKOU | IT M.A.Sc Student Département de génie logiciel et TI École de technologie supérieure | Université du Québec 1100, rue Notre-Dame Ouest Montréal (Québec) H3C 1K3 [image001]<http://etsmtl.ca/>
