flink 并行度大于1那么richmap的open函数会执行几次close函数会执行几次
如果Flink的并行度大于1,那么richmap的open函数会在每个并行任务的每个子任务上执行一次,也就是总共会执行并行度的次数。
而close函数也会在每个并行任务的每个子任务上执行一次,同样是总共会执行并行度的次数。
简而言之,open和close函数的执行次数都与并行度相关,都会执行并行度的次数。
原文地址: https://www.cveoy.top/t/topic/iVdh 著作权归作者所有。请勿转载和采集!