java - 如何使用IDE在storm生产集群中提交拓扑

Question

我遇到了一个问题必须使用“storm”客户端脚本提交拓扑，以便 StormSubmitter 知道要上传哪个 jar，同时使用 IDE 将拓扑提交到生产集群，而如果我使用 storm jar 命令在命令行中执行，它的运行就像天堂一样。我从 githublink 看到了相同的例子.

为了提交拓扑，我正在使用这些行

conf.put(Config.NIMBUS_HOST, NIMBUS_NODE);
conf.put(Config.NIMBUS_THRIFT_PORT,6627);
conf.put(Config.STORM_ZOOKEEPER_PORT,2181);
conf.put(Config.STORM_ZOOKEEPER_SERVERS,ZOOKEEPER_ID);
conf.setNumWorkers(20);
conf.setMaxSpoutPending(5000);
StormSubmitter submitter = new StormSubmitter();
submitter.submitTopology("test", conf, builder.createTopology());

请建议我这是否是正确的运行方法？

Answer 1

很好地找到了解决方案。当我们运行“storm jar”时，它会在提交的 jar 中触发 storm.jar 的属性标志。因此，如果我们想以编程方式提交一个 jar，那么只需以这种方式设置标志

System.setProperty("storm.jar", <path-to-jar>);

例如:

System.setProperty("storm.jar", "/Users/programming/apache-storm-1.0.1/lib/storm-core-1.0.1.jar");
StormSubmitter.submitTopology("myTopology", config, builder.createTopology());