知识点
相关文章
更多最近更新
更多Twitter storm 命令简介
2019-03-02 23:38|来源: 网路
Storm命令简介
提交Topologies
命令格式：storm jar 【jar路径】 【拓扑包名.拓扑类名】 【拓扑名称】
样例：storm jar /storm-starter.jar storm.starter.WordCountTopology wordcountTop
#提交storm-starter.jar到远程集群，并启动wordcountTop拓扑。
停止Topologies
命令格式：storm kill 【拓扑名称】
样例：storm kill wordcountTop
#杀掉wordcountTop拓扑。
启动nimbus后台程序
命令格式：storm nimbus
启动supervisor后台程序
命令格式：storm supervisor
启动drpc服务
命令格式：storm drpc
启动ui服务
命令格式：storm ui
启动REPL
REPL — read-evaluate-print-loop。
虽然clojure可以作为一种脚本语言内嵌在java里面，但是它的首选编程方式是使用REPL，这是一个简单的命令行接口，使用它你可以输入你的命令，执行，然后查看结果， 你可以以下面这个命令来启动REPL：
命令格式：storm repl
打印本地配置
命令格式：storm localconfvalue 【配置参数关键字】
举例：storm localconfvalue storm.zookeeper.servers
#根据指定参数打印本地配置的值。
打印远程配置
命令格式：storm remoteconfvalue 【配置参数关键字】
举例：storm remoteconfvalue storm.zookeeper.servers
#根据指定参数打印远程配置的值。
执行Shell脚本
命令格式：storm shell resourcesdir command args
打印CLASSPATH
命令格式：storm classpath
本文出自 “圆石技术之路” 博客，请务必保留此出处http://chenlx.blog.51cto.com/4096635/740014
转自：http://chenlx.blog.51cto.com/4096635/740014
相关问答
更多-
免责声明：我写了您在上述问题中引用的文章 。 但是，我对“任务”的概念有些困惑。 任务是组件的运行实例（spout还是螺栓）？ 执行者有多个任务实际上是说执行者多次执行相同的组件，我是否正确？ 是的，是的。 此外，在一般的并行性意义上，Storm将为一个喷口或螺栓生成一个专用的线程（执行器），但是由具有多个任务的执行器（线程）对并行性的贡献是什么？ 每个执行器运行多个任务不会增加并行级别 - 执行程序总是有一个线程用于其所有任务，这意味着任务在执行程序上连续运行。 正如我在文章中写道，请注意： 在拓扑开始后 ...
-
经过几次测试后，我设法解决了这个问题。 使用以下测试环境运行： - Windows 7 SP1 --Apache Storm 1.0.3 - Java 1.8.0_111 - Eclipse Mars.2（4.5.2） 在本地群集上运行拓扑的方法示例： private void runTopology(final StormTopology topology, final String topologyName, final long timeout) { LocalCluster localClust ...
-
建立风暴启动者：得到错误“POM for storm-core missing”(building storm-starter: getting error “POM for storm-core missing”)[2023-03-01]
我遇到了同样的问题，并从storm-user邮件列表档案中找到了答案，请参阅 http://mail-archives.apache.org/mod_mbox/storm-user/201404.mbox/%3C72091F29-8109-4A1C-A79D-DDD2D871737B%40petrolink.com%3E I encountered the same problem, and found the answer from storm-user mailing list archives, re ... -
让我们说你的风暴在/ home / your / download / storm解压缩 我将其定义为env变量 STORM_HOME="/home/your/download/storm" 因此您可以通过以下方式导出此变量 export STORM_HOME 不要忘记导入路径： export PATH=$PATH:$STORM_HOME/bin 然后你可以在其中使用storm命令。 Let us say your storm is unpacked at /home/your/download/storm ...
-
无法使用kafka-storm向apache storm提交拓扑(Unable to submit topology to apache storm using kafka-storm)[2022-04-07]
我最终通过使用maven repo中预编译的storm-kafka版本并在拓扑中添加过滤器螺栓而不是在spout本身中进行过滤来解决这个问题。 从而消除了对storm-core和storm-kafka本地编译的jar文件的需求。 这不是一个“解决方案”，但它是解决问题的一种方法。 I eventually worked around this problem by using a pre-compiled version of storm-kafka from a maven repo and adding ... -
我从来没有听说过DSMS一词，但是看一下维基百科上的描述，我认为Storm绝对可以说是DSMS。 来自维基百科： 它类似于数据库管理系统（DBMS）[...]但是，与DBMS相比，DSMS执行连续查询，该查询不仅执行一次，而且是永久安装的。 这听起来就像Storm一样。 但请注意，在Storm的情况下，它通常与DBMS结合使用。 例如，Storm可以提供One-time queries ， unlimited secondary storage等，维基百科说这与DSMS结合时缺乏DSMS。 I had ne ...
-
正如错误所示，您尝试在源代码中运行。 只需下载二进制版本https://storm.apache.org/downloads.html并按照安装说明https://storm.apache.org/documentation/Setting-up-a-Storm-cluster.html 之后，您可以准备jar文件并通过bin/storm jar yourJarFile.jar提交到集群（请参阅https://storm.apache.org/documentation/Command-line-clien ...
-
部署Storm构建JAR(Deploying Storm build JAR)[2023-11-14]
@Matthias J. Sax和大家，感谢您的帮助。 我在这里犯的错误是，我所遵循的部署过程是错误的。 要部署toplogy构建，我必须遵循以下流程， Jar必须被推入风暴AWS文件夹，然后必须在命令下运行以使其被Storm识别 rm -f * .out （nohup bin / storm nimbus> nimubus.out）＆ （nohup bin / storm supervisor> supervisor.out）＆ （nohup bin / storm jar topos / IoT.jar ... -
Apache Storm - 风暴启动器上的ClassNotFoundException(Apache Storm - ClassNotFoundException on storm-starter)[2023-04-25]
通过maven运行暴风雨拓扑不是要走的路。 您应该在命令行上使用bin/storm jar myJarFile.jar向集群提交拓扑（这也适用于本地模式）。 文件./target/original-storm-starter-0.11.0-SNAPSHOT.jar和./target/storm-starter-0.11.0-SNAPSHOT.jar是标准的maven工件，不能用于向集群提交拓扑。 您可以使用maven-jar-plugin （我建议您开始使用 - 您可能还需要使用maven-dependen ... -
您总是需要拥有比执行程序更多（或相同数量）的任务。 由于任务数量是固定的，因此您需要设置比初始执行程序更大的初始数字，以便能够在运行时期间扩展执行程序的数量。 您可以看到任务数量，作为执行者的最大数量： #executors <= #numTasks 有关详细信息，请参阅此处： https ： //storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html You always need to ...