java - 如何开发(本地)和部署Storm Topology(远程)？

Question

我目前在 Windows 机器上使用 Netbeans 开发拓扑。当我以本地模式部署时:
LocalCluster 集群 = new LocalCluster();
cluster.submitTopology("word-count", conf, builder.createTopology());
一切正常，但当我尝试:
StormSubmitter.submitTopology("word", conf, builder.createTopology());
它显然试图以集群模式部署拓扑但失败了，因为我没有在我的本地计算机上运行 storm nimbus。我确实在一个 Digital Ocean droplet 上部署了 storm，但我当前(但不方便)的解决方案是复制 JAR 文件并使用 storm jar... 命令进行部署。
我的问题是:有没有办法告诉 Netbeans 我的 nimbus IP 地址是什么，以便它可以远程部署它？ (节省我的时间)
在此先感谢您!

Answer 1

Check this link
现在我可以在 Netbeans 中开发拓扑，在本地测试它们，并最终将它们部署到集群上的 Nimbus。这个解决方案非常适合我!!!
添加到配置文件:
conf.put(Config.NIMBUS_HOST, "123.456.789.101); //YOUR NIMBUS'S IP
conf.put(Config.NIMBUS_THRIFT_PORT,6627); //int is expected here

此外，添加以下内容:
System.setProperty("storm.jar", <path-to-jar>); //link to exact file location (w/ dependencies)
以避免以下错误:
[main] INFO backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar...
Exception in thread "main" java.lang.RuntimeException: Must submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload.
干杯!