可能是因为你在 schema 中把 eventTime 声明成了 timestamp 类型,你可以声明成 long 试试。 
.field("_rowtime", Types.LONG())

> 在 2019年9月5日,15:11,hb <343122...@163.com> 写道:
> 
> 实际应用中, 时间字段最常用的就是Long类型的毫秒时间戳, 难道这个不支持么.

回复