flink实时流中如何实时获取当前时间？
RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间*来自志愿者整理的flink
展开
收起
1
条回答
写回答
写回答
-
在source表上加上 proctime AS PROCTIME()的字段 ， 下游取的时候就用proctime转，注意时差的问题。比如用FROM_UNIXTIME(CAST(proctime AS BIGINT), 'yyyy-MM-dd HH:mm:ss') 函数时，在table config里设置时区
streamTableEnv.getConfig().setLocalTimeZone(ZoneOffset.ofHours(8)); ``*来自志愿者整理的flink2021-12-05 22:34:26赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
