运行 Apache Storm 在本地模式下连接错误

Question

编辑：所以当我增加睡眠时间但仍然出现 connection/timeout 错误时，这得到了 "solved"

59297 [Thread-14] ERROR o.a.s.d.s.ReadClusterState - Failed to Sync Supervisor

这是我的自定义拓扑：

public class MyTopology {
    public static void main(String[] args) {
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("NameSpout", new NameSpout());
        builder.setBolt("NameBolt", new MyBolt()).shuffleGrouping("NameSpout");

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

        LocalCluster cluster = new LocalCluster();

        try {

            cluster.submitTopology("TryingOne", config, builder.createTopology());
            Thread.sleep(10000);
        } catch (Exception e) {
            e.printStackTrace();

        } finally {
            cluster.shutdown();
        }

    }

}

Answer 1

是的，LocalCluster 会处理它。使用 LocalCluster 时，您不应该运行您自己的 Zookeeper 服务器。

为了排除您运行进入的环境的问题，请尝试检查并运行使用此拓扑 https://github.com/apache/storm/blob/v1.2.2/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java。

如果可行，那是你的项目配置有问题。如果不是，则可能是您所在的环境存在问题。

运行 Apache Storm 在本地模式下连接错误

Running Apache Storm in local mode connection errors

java

multithreading

apache

apache-storm

executorservice