Apache Flink RichAsyncFunction open()是在初始化调用时调用一次，还是在每个函数调用时调用一次？

Apache Flink中的RichAsyncFunction是一个异步函数，用于在流处理任务中进行异步的数据处理操作。在RichAsyncFunction中，open()方法是在初始化调用时调用一次，而不是在每个函数调用时调用一次。

open()方法在RichAsyncFunction实例化时被调用，用于进行一些初始化操作，例如建立数据库连接、加载模型等。它通常用于创建一些只需要初始化一次的资源，以提高性能和效率。

在Flink的运行时环境中，每个RichAsyncFunction实例会被并行地执行，但open()方法只会在每个并行实例中调用一次。这意味着无论有多少并行任务，open()方法只会执行一次。

需要注意的是，open()方法的执行是在任务开始之前进行的，而不是在每个函数调用时执行。因此，如果需要在每个函数调用时执行某些操作，可以使用RichAsyncFunction中的asyncInvoke()方法。

总结起来，open()方法是在初始化调用时调用一次，用于进行一次性的初始化操作，而不是在每个函数调用时调用。