Re: 如何在KeyedProcessFunction中获取processingTime

ctx.timestamp()其实就是获取的StreamRecord的时间戳，也就是事件被提取出来的时间戳。 这个方法一般需要使用event time，并且在数据流上assign过timestamp和watermark。 ゞ野蠻遊戲χ 于2020年8月16日周日 下午7:57写道： > 大家好 > > > 当我在KeyedProcessFunction的processElement方法中获取processingTime，就像这样ctx.timestamp()，返回为null，我改如何在processElement中获取processingTime？ > > > 谢谢！ > 嘉治

Re: 如何在KeyedProcessFunction中获取processingTime

根据Context获取timerService，然后获取处理时间即可。 在 2020/8/16 下午7:57，“ゞ野蠻遊戲χ” 写入: 大家好 当我在KeyedProcessFunction的processElement方法中获取processingTime，就像这样ctx.timestamp()，返回为null，我改如何在processElement中获取processingTime？ 谢谢！ 嘉治