95-136-070-源码-Operator-扩展有状态的operators

1.美图 2.概述 ​ 对于流处理程序来说，一个常见的需求是：根据输入数据的速率，调节operators的并行度。对于无状态的operators 来说，扩展是很简单的。但是对于有状态的operators，会更具挑战性，因为他们的state需要被重新分区，并分配给更多或是更少的并行tasks。Flink支持四种模式，用于扩展不同类型的state。 ​ 对于keyed state的operators，

>>阅读原文<<