如何使用IDE在Storm生产集群中提交拓扑
我在Must submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload使用IDE向生产集群提交拓扑时遇到了一个问题，而如果我在命令行中使用storm jarcommand
执行同样的事情，它的运行就像天堂一样。我从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());
请建议我这是否是运行的正确方法？
问题答案：
很好找到解决方案。当我们运行“ 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());
-
> 灵光升起 StormUI启动 我使用的两个工人都起来了 Zookeper已启动 我和暴风一起跑 Storm罐myjar.jar MyClass Nimbus提交拓扑 该拓扑的日志文件不会出现在workers中。 我在supervisor.log上的worker中有以下日志： 所以我确信我与nimbus有连接问题，但是worker中的属性文件是： 错误在哪里，我如何修复它？ 谢了！
-
我读了很多和Storm有关的网站。但我仍然无法将拓扑结构完美地映射到Storm集群中。 请帮助我理解这一点。 在Storm集群中有这样的术语 null null null 所有这些都要用Storm集群来映射。我已经在一个项目里工作了。所以我知道拓扑结构。
-
现在我想在一个污点中使用Drools，它在LocalCluster中正常工作，但是当我把它放在生产集群中时，它有错误。污点是： 我使用官方文件创建了kiesession。误差为： 也许有些东西没有初始化。但当blot执行时，我创建了一个新的kieservice。有人能帮我吗 谢啦！
-
我一直在使用IDE（Eclipse）测试Storm拓扑的远程提交。我成功地将简单的storm拓扑上传到了远程storm集群,但奇怪的是,当我检查storm UI以确定远程提交的拓扑是否正常工作时,我在UI中看到了just_acker bolt,但其他bolt和spout却不在那里。之后，我从命令行手动提交了拓扑，并再次检查了Storm UI，它正常工作，没有问题。我一直在找原因，但没有找到。我在下
-
在生产集群上运行 Topology 类似于在 本地模式 下运行.以下是步骤： 1）定义 Topology （如果使用 Java 定义, 则使用 TopologyBuilder ） 2）使用 StormSubmitter 将 topology 提交到集群. StormSubmitter 以 topology 的名称, topology 的配置和 topology 本身作为输入.例如： Config
-
当我站在上面提交拓扑时，我在storm jar中遇到了问题 我写 打出来的 没有找到Storm指令 我想知道怎么了？ Storm罐之间的区别是什么。。。。和 都在提交拓扑？