运行感叹拓扑失败
~/src/storm-0.8.1/bin/storm jar/root/src/storm-starter/target/storm-starter-0.0.1-snapshot-jar-with-dependencies.jar storm.starter.exclamationtopology演示
我试着运行它，它说问题是与nimbus连接，但我的storm客户端（和supervisor在同一时间）与我的nimbus连接（显示在Strom UI中）
共有1个答案
这似乎表明您在试图运行此命令的计算机上连接到nimbus时遇到了麻烦。很可能您的~/.storm/storm.yaml中有问题。请确保您已正确配置了它以指向您的nimbus服务器。
-
我终于觉得我有了一个在redis数据库上写的toopology。我有一个插销要打印，还有一个插销要插入Redis。但当我尝试启动拓扑时,会出现以下错误：
-
我正在使用相同版本的petrel 0.9.3和apache storm。当我尝试运行拓扑时，会出现以下错误：
-
在生产集群上运行 Topology 类似于在 本地模式 下运行.以下是步骤： 1）定义 Topology （如果使用 Java 定义, 则使用 TopologyBuilder ） 2）使用 StormSubmitter 将 topology 提交到集群. StormSubmitter 以 topology 的名称, topology 的配置和 topology 本身作为输入.例如： Config
-
这个拓扑运行正常，不知道是什么原因导致这个问题。
-
我正在运行一个3节点的Storm集群。我们正在提交一个包含10个工作者的拓扑结构，以下是拓扑结构的详细信息 我们每天处理800万到1000万个数据。问题是topolgy只运行了2到3天，而我们在kafka spout中看到了一些失败的元组，没有处理任何消息。当提交新的topolgy时，它工作良好，但在2到3天后，我们又看到了同样的问题。有人能给我们一个解决方案吗。下面是我的storm配置
-
我有一个运行的storm拓扑开始使用一个打包的JAR。我正在尝试查找拓扑正在运行的jar的版本。据我所知，Storm只会显示正在运行的Storm版本，而不会显示正在运行的拓扑版本。 运行“storm version”命令只给出storm运行的版本，我在storm UI的拓扑部分中没有看到任何指示拓扑版本的内容。 有没有办法让Storm报告这一点，还是我最好的办法设置一个属性文件？理想情况下，这将通