apache flink TimerService回调和KeyedProcessFunction.prrocessEle



我有一个KeyedProcessFunction实现,它覆盖了"processElement(("one_answers"onTimer(("方法。它们彼此之间的螺纹安全吗?

onTimer((方法似乎是由TimerService的ad池调用的。所以在我看来,他们可能在同一时间被处决。

processElementonTimer从不并行执行。

在Flink 1.10之前,这两种方法都会在获取检查点锁后调用。

由于Flink 1.10,它们只能通过同一个任务线程调用,因此以非同步的方式访问字段是安全的(即使一开始不鼓励使用非托管字段(。

相关内容

  • 没有找到相关文章

最新更新