不行, Caused by: org.apache.flink.table.api.ValidationException: Rowtime attribute '_rowtime' is not of type SQL_TIMESTAMP.
在 2019-09-06 10:48:02,"Jark Wu" <imj...@gmail.com> 写道: >可能是因为你在 schema 中把 eventTime 声明成了 timestamp 类型,你可以声明成 long 试试。 >.field("_rowtime", Types.LONG()) > >> 在 2019年9月5日,15:11,hb <343122...@163.com> 写道: >> >> 实际应用中, 时间字段最常用的就是Long类型的毫秒时间戳, 难道这个不支持么. >