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