Storm命令行参数研究
[root@node1 ~]# storm
Commands:
activate
classpath
deactivate
dev-zookeeper
drpc
help
jar
kill
list
localconfvalue
logviewer
monitor
nimbus
rebalance
remoteconfvalue
repl
shell
supervisor
ui
version
Help:
help
help <command>
Documentation for the storm client can be found at http://storm.incubator.apache.org/documentation/Command-line-client.html
Configs can be overridden using one or more -c flags, e.g. "storm list -c nimbus.host=nimbus.mycompany.com"
[root@node1 ~]# storm help activate
Syntax: [storm activate topology-name]
Activates the specified topology's spouts.
-----------------------------------------------------------------------------------------------
activate storm activate topology-name
激活指定的任务
classpath storm classpath
打印storm的classpath
deactivate storm deactivate topology-name
暂停storm的任务
dev-zookeeper storm dev-zookeeper
启动一个新的Zookeeper,这种情况只用于dev/test
drpc storm drpc
启动一个DRPC进程
help
jar storm jar topology-jar-path class
运行你的storm job,topology是类中的主函数
kill storm kill topology-name [-w wait-time-secs]
通过任务名称kill一个任务,storm会先使任务接口无效,使已经存在的消息被处理完成,然后会关闭任务并清除状态,你可以使用-w延迟几秒后关闭任务
list storm list
列出正在运行的topolofies和状态
localconfvalue storm localconfvalue conf-name
打印出conf-name在本地storm配置文件中的值
nimbus storm nimbus
启动一个nimubs进程。
rebalance storm rebalance topology-name [-w wait-time-secs]
有时候你想扩展你的任务运行在某些机器上,比如你有10个节点,每个节点运行4个任务,然后又增加了10个节点,你希望每个节点运行2个任务,一种方法是kill掉任务,重新提交,但是storm提供rebalance命令来做这件事。
remoteconfvalue storm remoteconfvalue conf-name
打印出conf-name在storm cluster中的值
repl storm repl
打开一个clojure repl,对debugging有用
shell
supervisor storm supervisor
启动一个supervisor进程
ui storm ui
启动一个ui进程
version
logviewer
启动Logviewer守护进程。语法如下:
storm logviewer
Logviewer提供一个Web接口查看Storm日志文件。该命令应该使用daemontools或者monit工具监控运行。
相关推荐
1. **DRPC服务器设置**:启动DRPC服务器,这通常通过Storm的命令行工具完成。`storm drpc`命令会在本地启动一个DRPC服务器。 2. **创建DRPC拓扑**:编写一个Storm拓扑,其中包含DRPC bolt。DRPC bolt是执行DRPC请求...
接口配置命令是用于配置交换机物理接口(如以太网接口、光口等)的参数,例如设置速率限制的`rate-limit`、自动协商的`negotiation auto`、双工模式`duplex`、速率`speed`等。还包括了storm控制、优先级、MTU大小、...
5. **工具集**:包括Hadoop命令行工具,如fs、jar、dfsadmin等,以及HDFS的故障检测和诊断工具,帮助管理员监控和管理集群。 三、Hadoop Common 2.7.1的文件结构 在"**hadoop-common-2.7.1-bin-maste**"压缩包中,...
- **命令行格式约定**:包括基本格式约定、特殊字符以及参数格式。例如,“#”表示当前处于管理员模式;“?”用于显示参数列表或帮助信息;参数格式需遵循特定规则,如IP地址、掩码、MAC地址等的正确输入方式。 **2...
在实际应用中,可能还需要结合其他组件,如Apache Flume用于数据收集,Apache Storm或Apache Spark Streaming用于实时数据处理,以及Apache HBase或Apache Cassandra用于实时数据存储。 总的来说,了解并掌握Hadoop...
- **集成 Spark/Storm:** Kafka 也可以与 Spark 和 Storm 等流处理框架集成,实现更复杂的流处理逻辑。 **监控与运维:** - **监控指标:** Kafka 提供了大量的监控指标,可以帮助管理员了解系统的运行状态。 - **...
KMODE_EXCEPTION_NOT_HANDLED ***其中错误的第一部分是停机码(Stop Code)也就是STOP 0x0000001E, 用于识别已发生错误的类型, 错误第二部分是被括号括起来的四个数字集, 表示随机的开发人员定义的参数(这个参数对于...