Apache Flink RichAsyncFunction open() 是否在 init 或每个函数调用时被调用一次

Question

open(( 函数是在 init 上执行一次还是每次执行富函数时执行？

那么，如果我们想执行一个繁重的操作，比如创建一个数据库数据源，我们可以在那里完成，它不会在每次调用时启动？

Answer 1

open() 方法在运算符初始化期间针对运算符的每个并行实例调用一次。所以是的，这是你进行"繁重"的一次性初始化调用的地方。