我有一个KeyedProcessFunction实现,它覆盖了"processElement(("one_answers"onTimer(("方法。它们彼此之间的螺纹安全吗?
onTimer((方法似乎是由TimerService的ad池调用的。所以在我看来,他们可能在同一时间被处决。
processElement
和onTimer
从不并行执行。
在Flink 1.10之前,这两种方法都会在获取检查点锁后调用。
由于Flink 1.10,它们只能通过同一个任务线程调用,因此以非同步的方式访问字段是安全的(即使一开始不鼓励使用非托管字段(。