storm问题请教

[RLily]

我实现 CustomStreamGrouping接口，确保同一用户的数据能分配到同一个bolt；但是下游bolt所在的进程退出，该bolt在同一节点另一个worker中重启了，但是部分用户上传的数据没有传入重启的bolt，有的用户是可以的，能指教一下吗？

this.tasks = targetTasks;
numTasks = tasks.size();
int boltid = HashTask.BKDRHash(AccountName) % numTasks;
boltIds.add(tasks.get(boltid));
return boltIds;