0
我可以看到如何将字段内容和任务ID散列在一起用于保持字段中具有相同值的所有元组进入相同的螺栓任务。但是,如果有多名工人,他们应该如何保证?当然,螺栓任务不在工人之间共享?Apache Strom字段分组是否可以跨多个工作人员使用?
我可以看到如何将字段内容和任务ID散列在一起用于保持字段中具有相同值的所有元组进入相同的螺栓任务。但是,如果有多名工人,他们应该如何保证?当然,螺栓任务不在工人之间共享?Apache Strom字段分组是否可以跨多个工作人员使用?
当创建拓扑并且永不改变时,任务的数量是固定的。重新平衡命令可以改变哪个执行者托管一个任务,但是它们不会被销毁,因此具有相同字段值的元组将总是进入相同的任务,而不管它在哪个工作进程或执行器上。
您可能已经看到了这个,但this是Storm的并行性的一个很好的解释,并提供了更多的细节。