Apache Storm-Spout/Bolt高延迟崩溃

Question

当我的拓扑使用Storm 1.1.0时，我遇到了一个问题，当拓扑具有高延迟的Bolt时，Storm会重新安排Bolt和spout或者让Bolt和spout崩溃。

现在我创建了一个LatencyTest-Topology来测试和处理这个问题。

public void nextTuple() {
    outputCollector.emit(new Values(Math.random()));
}

public void execute(Tuple tuple) {
    double input = tuple.getDouble(0);
    try {
        Thread.sleep(this.latencyMS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    outputCollector.ack(tuple);
}

Answer 1

MaxSpoutPending不是超时配置，您应该配置的是topology.message.timeout。