我可以看到如何将字段内容和任务id散列在一起，以使字段中具有相同值的所有元组都指向同一个bolt任务。然而，如果有一个以上的工人，如何保证他们的安全呢？工人之间肯定不共享任务吗？
mnemlml81#
创建拓扑时，任务数是固定的，并且从不更改。重新平衡命令可以更改托管任务的执行器，但不会销毁这些执行器，因此具有相同字段值的元组将始终转到同一任务，而不管它在哪个工作进程或执行器上。你可能已经看到了这一点，但这是一个很好的解释风暴的平行性，并提供了更多的细节。
1条答案
按热度按时间mnemlml81#
创建拓扑时，任务数是固定的，并且从不更改。重新平衡命令可以更改托管任务的执行器，但不会销毁这些执行器，因此具有相同字段值的元组将始终转到同一任务，而不管它在哪个工作进程或执行器上。
你可能已经看到了这一点，但这是一个很好的解释风暴的平行性，并提供了更多的细节。