Flink 1.9 blink runner will support it as Generic Type, But I don't recommend it. After all, there are java.sql.Date and java.time.* in Java.
Best, JingsongLee ------------------------------------------------------------------ From:Flavio Pompermaier <pomperma...@okkam.it> Send Time:2019年7月8日(星期一) 15:40 To:JingsongLee <lzljs3620...@aliyun.com> Cc:user <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? 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 <lzljs3620...@aliyun.com> wrote: 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:Flavio Pompermaier <pomperma...@okkam.it> Send Time:2019年7月5日(星期五) 22:52 To:user <user@flink.apache.org> Subject:Flink Table API and Date fields 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.validate(FlinkPlannerImpl.scala:112) at org.apache.flink.table.planner.StreamPlanner.toRel(StreamPlanner.scala:148) at org.apache.flink.table.planner.StreamPlanner.parse(StreamPlanner.scala:114) at org.apache.flink.table.api.internal.TableEnvironmentImpl.sqlQuery(TableEnvironmentImpl.java:268) Caused by: org.apache.flink.table.api.TableException: Type is not supported: Date at org.apache.flink.table.calcite.FlinkTypeFactory$.org$apache$flink$table$calcite$FlinkTypeFactory$$typeInfoToSqlTypeName(FlinkTypeFactory.scala:357) Is there a way to deal with this without converting the Date field to a Long one? Best, Flavio
