当我在jstorm中使用三叉树时,一批中具有相同字段的元组在重新平衡后会被发送到不同的任务,那么三叉树的CombinerAggregator是如何工作的呢?
发布于 2015-12-29 12:50:20
如果任务编号改变,jstorm不能确保相同字段的元组被发送到相同的任务。因此,当我们在jstorm中进行重新平衡时,我们应该
https://stackoverflow.com/questions/34489751
相似问题