本地模式的话,先运行集群以后,在执行关闭cluster.shutdown();或则移除cluster.shutdown(); 也可以使用单点模式试试 cluster.submitTopology("word-count", conf, builder.createTopology()); Thread.sleep(10000); |
rsgg03 发表于 2015-3-4 16:00 版本是多少 据说自从v0.9.3 版本后,就不兼容以前版本了。 WordCountTopology需要更新等 |
1.storm是使用的本地模式,还是集群模式,最好不使用本地模式。 2. 注意python 和 ruby版本,最好 2.6+ |