Flink并行度大于1时RichMap的Open和Close函数执行时机详解

当Flink的并行度大于1时，richmap的open函数和close函数会在每个并行实例上分别执行。具体执行的时机如下：\n\n1. open函数：每个并行实例在开始处理数据之前都会执行一次open函数。在执行open函数之前，Flink会创建一个新的richmap实例，并为其分配资源。\n\n2. close函数：每个并行实例在处理完数据之后都会执行一次close函数。在执行close函数之后，Flink会释放该richmap实例所占用的资源。\n\n对于一条数据是否执行一次open和close函数，取决于数据的处理方式。在richmap中，open和close函数是在整个任务的生命周期内只执行一次的，而map函数是对每条输入数据都执行一次的。\n\n因此，在并行度大于1的情况下，对于每个并行实例而言，open函数只会执行一次，而map函数会对每条输入数据都执行一次，然后close函数也只会执行一次。