Re: Flink Table API and Date fields

2019-07-08 Thread Rong Rong
t; Best, JingsongLee >> >> ------------------ >> From:Flavio Pompermaier >> Send Time:2019年7月8日(星期一) 15:40 >> To:JingsongLee >> Cc:user >> Subject:Re: Flink Table API and Date fields >> >>

Re: Flink Table API and Date fields

2019-07-08 Thread Timo Walther
Send Time:2019年7月8日(星期一) 15:40 To:JingsongLee mailto:lzljs3620...@aliyun.com>> Cc:user mailto:user@flink.apache.org>> Subject:Re: Flink Table API and Date fields I think I could do it for this specific use case but isn't this a big limitation of Table API?

Re: Flink Table API and Date fields

2019-07-08 Thread Flavio Pompermaier
a. > > Best, JingsongLee > > -- > From:Flavio Pompermaier > Send Time:2019年7月8日(星期一) 15:40 > To:JingsongLee > Cc:user > Subject:Re: Flink Table API and Date fields > > I think I could do it for this specifi

Re: Flink Table API and Date fields

2019-07-08 Thread JingsongLee
15:40 To:JingsongLee Cc:user Subject:Re: Flink Table API and Date fields I think I could do it for this specific use case but isn't this a big limitation of Table API? I think that java.util.Date should be a first class citizen in Flink.. Best, Flavio On Mon, Jul 8, 2019 at 4:06 AM JingsongLee

Re: Flink Table API and Date fields

2019-07-08 Thread Flavio Pompermaier
I think I could do it for this specific use case but isn't this a big limitation of Table API? I think that java.util.Date should be a first class citizen in Flink.. Best, Flavio On Mon, Jul 8, 2019 at 4:06 AM JingsongLee wrote: > Hi Flavio: > Looks like you use java.util.Date in your pojo, Now

Re: Flink Table API and Date fields

2019-07-07 Thread JingsongLee
Hi Flavio: Looks like you use java.util.Date in your pojo, Now Flink table not support BasicTypeInfo.DATE_TYPE_INFO because of the limitations of some judgments in the code. Can you use java.sql.Date? Best, JingsongLee -- From:F

Flink Table API and Date fields

2019-07-05 Thread Flavio Pompermaier
Hi to all, in my use case I have a stream of POJOs with Date fields. When I use Table API I get the following error: Exception in thread "main" org.apache.flink.table.api.ValidationException: SQL validation failed. Type is not supported: Date at org.apache.flink.table.calcite.FlinkPlannerImpl.vali