Flink RichMap Open 和 Close 函数执行时机详解

当 Flink 作业的并行度大于 1 时，RichMap 的 open 函数会在每个并行任务的子任务启动时执行一次，而 close 函数会在每个并行任务的子任务关闭时执行一次。

具体来说，当 Flink 作业启动时，会为每个并行任务创建一个子任务，然后在每个子任务启动之前，会调用 RichMap 函数的 open 方法。在子任务执行过程中，RichMap 函数的 map 方法会被多次调用，对输入数据进行转换。当一个子任务执行完毕后，会调用 RichMap 函数的 close 方法。

需要注意的是，open 和 close 方法的执行是在并行任务的生命周期内进行的，而不是在整个作业的生命周期内。每个子任务都会有自己独立的 open 和 close 方法执行。