storm-lib
storm-lib copied to clipboard

Published 20 hours ago •

xumingming

→

Metadata

hold storm examples, tests etc here.

Reame
Issues

Results 1 storm-lib issues

Sort by recently updated

storm问题请教

我实现 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;

RLily