Re: [External] Re: Exception when running Java UDF with Blink table planner

uot;"".stripMargin > ) > tEnv.createFunction("ListToString", classOf[ListToString]) > tEnv.executeSql("SELECT ListToString(`person`) as col1_string FROM > `test2`").print() > } > ``` > 4. Then you can debug the case in your IDEA. > >

Re: [External] Re: Exception when running Java UDF with Blink table planner

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 > >

Re: [External] Re: Exception when running Java UDF with Blink table planner

Thanks, Tom On Thu, May 26, 2022 at 7:47 PM Shengkai Fang wrote: > 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 > >

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 String eval(List list) { return "foo"; } Since moving to the Blink table plan

Re: [External] Re: Potential Bug with Date Serialization for Table Stream

/github.com/MartijnVisser > > [1] https://issues.apache.org/jira/browse/FLINK-24403 > [2] https://lists.apache.org/thread/qpzz298lh5zq5osxmoo0ky6kg0b0r5zg > > > On Tue, 22 Mar 2022 at 18:06, Tom Thornton wrote: > >> Hi Martijn, >> >> Do you know what could be c

Re: [External] Re: Potential Bug with Date Serialization for Table Stream

Hi Martijn, Do you know what could be causing this issue given our Flink version? Is this possibly a bug with that version? Thanks, Tom On Thu, Mar 17, 2022 at 9:59 AM Tom Thornton wrote: > Hi Martijn, > > We are using 1.11.6. > > Thank you for the help. > > On Thu, Ma

Re: [External] Re: Potential Bug with Date Serialization for Table Stream

Hi Martijn, We are using 1.11.6. Thank you for the help. On Thu, Mar 17, 2022 at 1:37 AM Martijn Visser wrote: > Hi Tom, > > Which version of Flink are you using? > > Best regards, > > Martijn Visser > https://twitter.com/MartijnVisser82 > > > On Wed, 16 Mar 2

Potential Bug with Date Serialization for Table Stream

Per the docs , I'm hoping to confirm whether or not an error we are seeing is a bug with Flink. We have a job that uses a Kafka source to read Avro records. The kafka source is converted into a StreamTableSource. We are using the new Blink tabl