当前位置: 首页 > 知识库问答 >
问题:

查找Apache Storm中运行的拓扑jar版本

周云
2023-03-14

我有一个运行的storm拓扑开始使用一个打包的JAR。我正在尝试查找拓扑正在运行的jar的版本。据我所知,Storm只会显示正在运行的Storm版本,而不会显示正在运行的拓扑版本。

运行“storm version”命令只给出storm运行的版本,我在storm UI的拓扑部分中没有看到任何指示拓扑版本的内容。

有没有办法让Storm报告这一点,还是我最好的办法设置一个属性文件?理想情况下,这将通过pom.xml版本或git提交散列自动完成。另一个我很乐意的解决方案是让Storm报告用于启动拓扑的jar文件名。

共有1个答案

蒲昀
2023-03-14

一种方法可以是列出

$storm_home/storm-local/supervisor/stormdist/name-of-your-running-topology

并查看stormjar.jar文件。这是storm在提交拓扑时使用的uber jar。将这个jar的大小与从您的Java项目构建命令中生成的uber jar进行比较,它们应该是相同的,并给出关于所使用的jar版本的提示。

 类似资料:
  • 我终于觉得我有了一个在redis数据库上写的toopology。我有一个插销要打印,还有一个插销要插入Redis。但当我尝试启动拓扑时,会出现以下错误:

  • ~/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在同

  • 我正在使用相同版本的petrel 0.9.3和apache storm。当我尝试运行拓扑时,会出现以下错误:

  • > 灵光升起 StormUI启动 我使用的两个工人都起来了 Zookeper已启动 我和暴风一起跑 Storm罐myjar.jar MyClass Nimbus提交拓扑 该拓扑的日志文件不会出现在workers中。 我在supervisor.log上的worker中有以下日志: 所以我确信我与nimbus有连接问题,但是worker中的属性文件是: 错误在哪里,我如何修复它? 谢了!

  • 当我站在上面提交拓扑时,我在storm jar中遇到了问题 我写 打出来的 没有找到Storm指令 我想知道怎么了? Storm罐之间的区别是什么。。。。和 都在提交拓扑?

  • 在生产集群上运行 Topology 类似于在 本地模式 下运行.以下是步骤: 1)定义 Topology (如果使用 Java 定义, 则使用 TopologyBuilder ) 2)使用 StormSubmitter 将 topology 提交到集群. StormSubmitter 以 topology 的名称, topology 的配置和 topology 本身作为输入.例如: Config