hazelcast-jet - 如何在 hazelcast 喷气机集群的新节点找到工作

Question

谁能说新的喷气机集群实例应该如何开始工作？

用例 1：

1. 通过 3 个节点启动 jet 集群
2. 提交作业到集群
3. 所有 3 个节点都开始作业并处理数据

用例 2：

1. 启动第 4 个节点
2. 第 4 个节点什么也不做，因为它不是新的提交作业命令

新的集群实例应该如何启动已经在另一个节点上启动的作业？

Answer 1

您要求的功能计划用于 Jet 0.5，计划于 2017 年 9 月结束。

在 Jet 0.4 中，您必须取消当前作业并重新启动它，但是您将丢失处理器状态。另请注意，通过取消提交作业的客户端不会取消作业，您必须使用：

Future<Void> future = jetInstance.newJob().execute();
// some time later
future.cancel();