在本地模式下运行apache storm连接错误

yfwxisqw  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(325)

编辑:所以当我增加睡眠时间,但仍然出现连接/超时错误时,这个问题得到了“解决”

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();
        }

    }

}
5jdjgkvh

5jdjgkvh1#

是的,localcluster会处理的。使用localcluster时不应该运行自己的zookeeper服务器。
为了排除运行环境中的问题,请尝试 checkout 并运行此拓扑https://github.com/apache/storm/blob/v1.2.2/examples/storm-starter/src/jvm/org/apache/storm/starter/exclamationtopology.java.
如果它工作,这将是一个与您的项目配置问题。如果不是的话,你所处的环境可能有问题。

相关问题