开发者社区 问答 正文

DataStream[Row] 转table怎么指定.proctime字段?

转自钉钉群21789141:请问下,DataStream[Row] 转table怎么指定.proctime字段? 如果在xxx中增加了updated_time.proctime字段
tableEnv.fromDataStream( rowStream, xxx )
会报错updated_time.proctime is not a field of type Row(uid: Long, id: Long). Expected: uid, id

看官网上的例子是在DataStream[(String, String)] 中增加的.proctime字段,是不是DataStream[Row] 不支持设置.proctime字段呢?

展开
收起
赵慧@ApacheFlink中文社区 2018-10-18 12:48:06 4319 分享 版权
1 条回答
写回答
取消 提交回答
问答地址: