Hi
报错信息是query的schema和sink table 的schema信息不匹配,

>  tumble_start(proctimeField, INTERVAL '10' SECOND) as tum
是保留时间属性的,对应的类型是TimeIndicatorTypeInfo, 如果要转到TIMSTAMP,你可以在输出前, 
cast下tum字段的类型到TIMESTAMP(3)

祝好
Leonard

回复