Acmed 2015-02-02 03:19 采纳率: 0%
浏览 2450

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

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

  • 写回答

1条回答 默认 最新

  • Acmed 2015-02-06 03:13
    关注

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

    评论

报告相同问题？

悬赏问题

  • ¥15 神经网络预测均方误差很小 但是图像上看着差别太大
  • ¥15 Oracle中如何从clob类型截取特定字符串后面的字符
  • ¥15 想通过pywinauto自动电机应用程序按钮，但是找不到应用程序按钮信息
  • ¥15 如何在炒股软件中，爬到我想看的日k线
  • ¥15 seatunnel 怎么配置Elasticsearch
  • ¥15 PSCAD安装问题 ERROR: Visual Studio 2013, 2015, 2017 or 2019 is not found in the system.
  • ¥15 (标签-MATLAB|关键词-多址)
  • ¥15 关于#MATLAB#的问题，如何解决？（相关搜索：信噪比，系统容量）
  • ¥500 52810做蓝牙接受端
  • ¥15 基于PLC的三轴机械手程序