提交拓扑时找不到Storm？
当我站在上面提交拓扑时，我在storm jar中遇到了问题
storm starter/src/jvm/storm/starter/
我写
storm jar ExclamationTopology.jar storm.starter.ExclamationTopology arg1
打出来的
没有找到Storm指令
我想知道怎么了？
Storm罐之间的区别是什么。。。。和
mvn -f m2-pom.xml compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology
都在提交拓扑？
共有1个答案
确保按此处所述将Storm bin目录放置在路径上。
是的，您可以使用Maven（此处描述）或storm命令（此处描述）运行拓扑。
-
我一直在使用IDE（Eclipse）测试Storm拓扑的远程提交。我成功地将简单的storm拓扑上传到了远程storm集群,但奇怪的是,当我检查storm UI以确定远程提交的拓扑是否正常工作时,我在UI中看到了just_acker bolt,但其他bolt和spout却不在那里。之后，我从命令行手动提交了拓扑，并再次检查了Storm UI，它正常工作，没有问题。我一直在找原因，但没有找到。我在下
-
这是我尝试运行的基本wordcount拓扑。但我收到的错误是“信息组织”。阿帕奇。暴风雨动物园管理员。服务器SessionTrackerImpl-SessionTrackerImpl已退出循环！'。有人能帮我吗？？ 当我移除集群时。shutdown（），在我按下cntrl c之前，tweets会一直出现。wordcount也不会显示##
-
我正在运行一个3节点的Storm集群。我们正在提交一个包含10个工作者的拓扑结构，以下是拓扑结构的详细信息 我们每天处理800万到1000万个数据。问题是topolgy只运行了2到3天，而我们在kafka spout中看到了一些失败的元组，没有处理任何消息。当提交新的topolgy时，它工作良好，但在2到3天后，我们又看到了同样的问题。有人能给我们一个解决方案吗。下面是我的storm配置
-
我正在设计一个ApacheStorm拓扑（使用streamparse），它由一个喷口（ApacheKafka喷口）和一个具有并行性的螺栓构建 螺栓分批读取信息。如果批量成功完成，我手动提交apache kafka偏移。 当mysql上的螺栓插入失败时，我不会在Kafka中提交偏移量，但是一些消息已经在喷口发送到螺栓的消息队列中。 应该删除队列中已经存在的消息，因为我无法在不丢失先前失败消息的情况下
-
我终于觉得我有了一个在redis数据库上写的toopology。我有一个插销要打印，还有一个插销要插入Redis。但当我尝试启动拓扑时,会出现以下错误：
-
问题内容： 我在使用IDE向生产集群提交拓扑时遇到了一个问题，而如果我在命令行中使用command 执行同样的事情，它的运行就像天堂一样。我从githublink看到了同样的例子。 为了提交拓扑，我正在使用这些行集 请建议我这是否是运行的正确方法？ 问题答案： 很好找到解决方案。当我们运行“ storm jar”时，它将在提交的jar中触发storm.jar的属性标志。因此，如果我们要以编程方式提