Flink State API v2异步Future回调中调用Timer Service与Collector是否线程安全？

直接给结论：在State API v2的异步Future回调里调用Timer Service和Collector是完全线程安全的。

为啥安全？

• Flink State API v2的异步回调机制，会把回调逻辑调度到算子的**主线程（也就是处理业务逻辑的那个线程）**里执行，不是在异步IO线程直接跑。
• 虽然Timer Service和Collector本身不是线程安全的组件，但因为回调是在算子主线程里触发的，不存在多线程并发访问的情况，所以不会有线程安全问题。

你贴的这段示例代码是安全的，放心用：

final var stateFuture = state.asyncValue();
stateFuture.thenAccept(value -> {
    ctx.timerService().registerEventTimeTimer(timestamp + someValue);
    out.collect(foo(value));
});

最后提个注意点：别在回调里自己开新线程去调用Timer Service或者Collector，这会破坏Flink的线程模型，反而引出线程安全问题。所有和算子运行时交互的操作，都通过State API v2的异步回调接口来做就对了。

内容的提问来源于stack exchange，提问作者thekey.kim