如何在 hazelcast jet 集群的新节点找到工作

Question

谁能说说新的 jet 集群实例应该如何启动作业？

用例 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();