flink 并行度大于1那么richmap的open和close函数在什么时候执行是一条数据执行一次吗
当Flink的并行度大于1时,richmap的open函数和close函数会在每个并行实例上分别执行。具体执行的时机如下:
-
open函数:每个并行实例在开始处理数据之前都会执行一次open函数。在执行open函数之前,Flink会创建一个新的richmap实例,并为其分配资源。
-
close函数:每个并行实例在处理完数据之后都会执行一次close函数。在执行close函数之后,Flink会释放该richmap实例所占用的资源。
对于一条数据是否执行一次open和close函数,取决于数据的处理方式。在richmap中,open和close函数是在整个任务的生命周期内只执行一次的,而map函数是对每条输入数据都执行一次的。
因此,在并行度大于1的情况下,对于每个并行实例而言,open函数只会执行一次,而map函数会对每条输入数据都执行一次,然后close函数也只会执行一次。
原文地址: https://www.cveoy.top/t/topic/iVdz 著作权归作者所有。请勿转载和采集!