flink 并行度大于1那么richmap的open和close函数在什么时候执行

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

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

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