我们正在研究如何动态缩放flink任务。任务即将在kafka主题中读取流媒体并做…然后沉入另一个kafka主题。我们知道必须停止flink工作……
您是否有理由不想通过停止工作来修改并行性?
您可以这样做,但是您可以有效地在各种作业中分割数据。因此,您不仅要承担现在需要了解多个作业的吞吐量以高效自动缩放的成本,而且还要使得任何有状态的处理都会导致不正确/不一致的结果。