考虑Flink中的FlatMapFunction。任何实施都必须序列化。
我试图理解为什么是这种情况，有人可以解释吗？在工作经理上创建的所有这些操作员实例是否比序列化并发送给任务经理？
在工作经理上创建的所有这些操作员实例是否比序列化并发送给任务经理？
您已经回答了您的问题:)这正是发生的。
值得一提的是，它不仅用于分布式作业，而且也用于容错。
系统从检查点恢复数据，然后重新删除整个分布式数据流，并为每个操作员提供作为检查点的一部分的状态。