flink在source中定义了eventtime和watermark,可以在sink时从context中获取eventtime吗

2020-05-25 Thread Jie Wong
source是kafka,在ddl中定义了eventtime和watermark,sink是streamfilesink,想在sink时根据事件时间进行分区,事件事件想从context中获取timestamp,但是发现为空。请问,context中的timestamp是值的是source中定义的eventtime吗?

Re: flink在source中定义了eventtime和watermark,可以在sink时从context中获取eventtime吗

2020-11-02 Thread marble.zh...@coinflex.com.INVALID
方便贴出代码吗,这样容易理解。 -- Sent from: http://apache-flink.147419.n8.nabble.com/