编辑:所以当我增加 sleep 时间但仍然出现连接/超时错误时,这个问题得到了“解决”
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();
}
}
}
最佳答案
是的,LocalCluster 会处理它。使用 LocalCluster 时,不应运行自己的 Zookeeper 服务器。
为了排除您运行环境的问题,请尝试检查并运行此拓扑 https://github.com/apache/storm/blob/v1.2.2/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java .
如果它有效,这将是您的项目配置的问题。如果没有,您所处的环境可能存在问题。
关于java - 在本地模式下运行 Apache Storm 连接错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56199726/