storm 事务处理(BaseBatchBolt)的并行度

我建立了一个批处理的bolt,StatisticBolt extends BaseBatchBolt,设置其并行度为2,
在其中的exceute 和finishBathc方法中打印了batchId和this.hashCode,发现对于每一个
batch,finishBatch会被调用两次,其中一个其实未收到任何的tuple,而且对于对于每一个
batch,hashCode都会不同(标准的BaseBasicBolt则所有batch都相同)。所有请问,storm对于BatchBolt的并行度是如何处理的呢? 每次处理batch的batchbolt对象(是否是对象)是如何生成的呢?

1个回答

没人回答啊。。。。。。。。。。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问