0

这是交易；

我正在处理在运行集群（flink statefun 2.2.1）时添加新的工作人员（嵌入式）。

如您所见，新的任务管理器可以注册到集群；

新部署的任务管理器的屏幕截图

但它没有初始化（它没有部署源）；

我在这里想念什么？（master和workers也必须相同的jar文件？或者使用jar文件部署taskmanager就足够了）

任何帮助将不胜感激，谢谢。

4

1 回答 1

0

Flink 支持两种不同的重新缩放方法：active和reactive。

Reactive 模式是 Flink 1.13（本周刚刚发布）中的新功能，并且可以按您预期的方式工作：添加（或删除）任务管理器，您的应用程序将适应新的并行性。您可以在文档中阅读有关弹性缩放和反应模式的信息。反应模式目前正在进行中，但可能需要您的需求。

概括地说，对于主动模式重新缩放，您需要：

  1. 使用保存点停止以关闭当前工作，同时对其状态进行快照。
  2. 以新的并行度重新启动，使用保存点作为起点。

确切的详细信息取决于您的集群的部署方式。

有关分步教程，请参阅在Flink Operations Playground中升级和重新缩放作业。

以上适用于重新调整 statefun 嵌入式函数。由于是无状态的，远程功能可以更直接地重新调整。

于 2021-05-07T18:00:56.510 回答