Hi zjfplayer， 可以使用 Now() 函数，详见：https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/functions/systemFunctions.html#temporal-functions Now() 函数是 not deterministic，意思是对于每条记录都会重新计算。
Best， Hailong Wang 在 2020-10-30 10:17:27，"[email protected]" <[email protected]> 写道： >RT，sql方式中怎么实时取当前消息处理的时间，来插入数据库当作当前更新时间？现在用current_timestamp发现不会变，只是第一次的时间 > > > >[email protected]
