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()方法中使用,以确保在所有执行器中均发出元组。

相关内容

热门资讯

实测必看!小程序雀神麻将来牌技... 实测必看!小程序雀神麻将来牌技巧(透视)太坑了竟然真的有挂(有挂攻略)-哔哩哔哩1、许多玩家不知道小...
终于知道!鄱阳翻精系统发牌机制... 终于知道!鄱阳翻精系统发牌机制(wepOkE),太坑了原来是真的有挂(有挂介绍)-哔哩哔哩;亲,其实...
透视透明(nzt德州)外挂透明... 透视透明(nzt德州)外挂透明挂辅助器(德州)发牌规律(2021已更新)(哔哩哔哩)是一款可以让一直...
一分钟教你!小程序边锋干瞪眼辅... 一分钟教你!小程序边锋干瞪眼辅助app,uupoker有挂,详细有挂(有挂教学)-哔哩哔哩;小程序边...
分享个大家!雀神辅助器叫名字(... 分享个大家!雀神辅助器叫名字(辅助挂)太坑了原来是真的有挂(有挂详情)-哔哩哔哩;最新版2024是一...
总算清楚!小程序边锋干瞪眼辅助... 总算清楚!小程序边锋干瞪眼辅助app,fishpoker脚本作弊,详细有挂(有挂规律)-哔哩哔哩小程...
透视透明挂(aapoker下载... 透视透明挂(aapoker下载)外挂透明挂辅助器安装(俱乐部)软件透明挂(2024已更新)(哔哩哔哩...
透视有挂!边锋斗地主看底牌软件... 透视有挂!边锋斗地主看底牌软件(wEpoKe),太坑了果真是真的有挂(有挂攻略)-哔哩哔哩;揭秘教程...
透视好友房(WPK开挂)外挂透... 1、透视好友房(WPK开挂)外挂透明挂辅助器(德州)透视辅助(2020已更新)(哔哩哔哩);详细教程...
最新技巧!雀神外挂真实测试(辅... 最新技巧!雀神外挂真实测试(辅助挂)太坑了的确是真的有挂(有挂详情)-哔哩哔哩;雀神外挂真实测试是一...