我试着用三叉戟做一个小例子。我们的目标是观察元组在失败时是如何重放的。下面是拓扑定义

Random rand = new Random();

        Config config = new Config();
        config.setDebug(true);
        config.setNumWorkers(1);

        TridentTopology topology = new TridentTopology();

        topology.newStream("spout", new RandomIntegerSpout())
                .map((MapFunction) tridentTuple -> {
                    if ((tridentTuple.getLongByField("msgid") % 50 == 0) &&
                            (rand.nextInt(2) == 1)) {
                        System.out.println(String.format("Failed to process tuple %d", tridentTuple.getLongByField("msgid")));
                        throw new ReportedFailedException("Divisible by 50");
                    }
                    return new Values(tridentTuple.toArray());
                })
                .peek((Consumer) tridentTuple -> System.out.println(tridentTuple.getValues()));

我使用 RandomIntegerSpout 从风暴开始 BaseRichSpout 产生随机数。然后我申请 MapFunction 它只是每50个元组抽取一个随机数，然后随机地使元组失败。
问题是，我没有得到任何 ack s或 fail s。
我玩了一下喷口，在调试模式下运行它，尝试了相同的示例输出，用标准的风暴螺栓进行了尝试。锚定工作正常，只是没有被三叉戟呼叫。
我在1.2.3版和2.0.0版中用localcluster和stormsubmitter重现了这个问题。
下面是storm ui的截图：

与map-ack和tuple对应的螺栓如预期的那样失败，但是这永远不会传播回喷口。
我原以为三叉戟大师会期望某种状态下的持久性来实现拓扑完成，但用某种持久聚合替换peek并没有帮助。我还排除了 map 用同样的方法 each .
查看代码几乎是微不足道的检查，我可能误解了一些基本的三叉戟/风暴。我以为三叉戟会叫喷口的 ack 方法是否完成了批处理？我意识到没有 fail 中的方法 IBatchSpout . 三叉戟如何处理批量回放？？