【发布时间】:2017-04-18 14:06:51
【问题描述】:
我可以看到如何将字段内容和任务 ID 散列在一起,以使字段中具有相同值的所有元组都转到同一个螺栓任务。但是,如果有多个工人,如何保证?确定螺栓任务不是在工人之间共享的吗?
【问题讨论】:
标签: java apache apache-storm
我可以看到如何将字段内容和任务 ID 散列在一起,以使字段中具有相同值的所有元组都转到同一个螺栓任务。但是,如果有多个工人,如何保证?确定螺栓任务不是在工人之间共享的吗?
【问题讨论】:
标签: java apache apache-storm
创建拓扑时任务的数量是固定的,永远不会改变。重新平衡命令可以更改哪些执行器托管任务,但它们不会被销毁,因此具有相同字段值的元组将始终执行相同的任务,无论它位于哪个工作进程或执行器上。
您可能已经看过了,但this 很好地解释了 Storm 的并行性,并提供了更多细节。
【讨论】: