Apachestorm的spout没有向bolt的所有执行器发出元组。
创始人
2024-09-06 12:30:39
0

在storm的代码中,可以使用以下方法解决该问题:

  1. 检查代码,确保spout的输出流与bolt的输入流匹配。

  2. 确认您的拓扑图中spout和bolt的配置和设置都正确。

  3. 确认spout的nextTuple()方法是否被正确地实现。

以下是一些示例代码,这些代码可以在Spout的nextTuple()方法中使用,以确保在所有执行器中均发出元组:

//方法一:
@Override
public void nextTuple() {
    List tuple = getTuple();
    for (int i = 0; i < outputFields.size(); i++) {
        collector.emit(new ArrayList(tuple), i);
    }
}

//方法二:
@Override
public void nextTuple() {
    List tuple = getTuple();
    if (lastTaskId < 0) {
        lastTaskId = context.getThisTaskId();
    }
    for (int i = lastTaskId + 1; i <= lastTaskId + boltParallelism; i++) {
        int taskId = i % boltParallelism;
        if (taskId == context.getThisTaskId()) {
            collector.emit(new ArrayList(tuple));
        } else {
            collector.emitDirect(taskId, new ArrayList(tuple));
        }
    }
    lastTaskId++;
    if (lastTaskId >= boltParallelism) {
        lastTaskId = 0;
    }
}

这些方法可以在Spout的nextTuple()方法中使用,以确保在所有执行器中均发出元组。

相关内容

热门资讯

总算清楚!潮汕雀友会辅助,we... 【福星临门,好运相随】;总算清楚!潮汕雀友会辅助,wepoker开辅助能查到吗,微扑克教程(有挂解密...
详细说明!创思维激K辅助器开挂... 详细说明!创思维激K辅助器开挂,雀神麻将小程序辅助软件(其实存在有挂);1、起透看视 雀神麻将小程序...
玩家必备教程!789大菠萝攻略... 玩家必备教程!789大菠萝攻略,wepokerplus透视脚本免费,2025新版总结(有挂秘诀);1...
玩家必知教程!微信链接透视脚本... 玩家必知教程!微信链接透视脚本下载,微信填大坑辅助(总是存在有挂)微信链接透视脚本下载能透视中分为三...
免费测试版!小程序河北微乐脚本... 免费测试版!小程序河北微乐脚本,wejoker辅助器要钱玩吗,黑科技教程(有挂秘籍),小程序河北微乐...
科普!潮友会app下载安卓,微... 科普!潮友会app下载安卓,微乐家乡官方app下载(果然真的是有挂)1、金币登录送、破产送、升级送、...
查到实测!微信小程序游戏辅助,... 查到实测!微信小程序游戏辅助,wepoker有没有辅助,2025版教程(真实有挂);查到实测!微信小...
重大通报!天天爱消除自动消除辅... 重大通报!天天爱消除自动消除辅助,微乐陕西小程序破解器下载(竟然有挂)一、微乐陕西小程序破解器下载可...
实测发现!微信小程序辅助器脚本... 您好:微信小程序辅助器脚本这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户...
一分钟了解!川娱竞技插件,哥哥... 一分钟了解!川娱竞技插件,哥哥打大a辅助辅助(竟然有挂)1、下载好哥哥打大a辅助辅助正确养号方法之后...