文档章节

storm命令行

 张欢19933
发布于 2017/03/27 11:36
字数 683
阅读 36
收藏 0

1.activate

激活指定的拓扑。语法如下:

storm activate topology-name

2.classpath

打印出Storm客户端运行命令时使用的类路径(classpath)。语法如下:

storm classpath

3.deactivate

暂停指定的拓扑Spout。语法如下:

storm deactivate topology-name

4.drpc (常用!)

启动一个DRPC守护进程。语法如下:

storm drpc

注:该命令应该使用daemontools或者monit工具监控运行。

5.help (常用!)

打印一条帮助消息或者可用命令的列表。语法如下:

storm help
storm help <command>

6.jar (很常用!)

运行类的指定参数的main方法。语法如下:

storm jar topology-jar-path class ...

注:把Storm的jar文件和"~/.storm"的配置放到类路径(classpath)中,以便当拓扑提交时,StormSUbmitter会上传topology-jar-path的jar文件。

7.kill (常用!)

杀死名为topology-name的拓扑。语法如下:

storm kill topology-name [-w wait-time-secs]

注:storm首先会在拓扑的消息超时时间期间禁用spout,以允许所有正在处理的消息完成。然后,Storm将会关闭Worker并清理他们的状态。可以使用-w标记覆盖Storm在禁用与关闭期间等待的时间长度。

8.list (常用!)

列出正在运行的拓扑及其状态。语法如下:

storm list

9.localconfvalue

打印出本地Storm配置的conf-name的值。语法如下:

storm localconfvalue conf-name

注:本地Storm配置是~/.storm/storm.yaml与defaults.yaml合并的结果。

10.logviewer (常用!)

启动Logviewer守护进程。语法如下:

storm logviewer

注:Logviewer提供一个Web接口查看Storm日志文件。该命令应该使用daemontools或者monit工具监控运行。

11.nimbus (常用!)

启动Nimbus守护进程。语法如下:

storm nimbus

注:该命令应该使用daemontools或者monit工具监控运行。

12.rebalance (常用!)

再平衡即动态设置拓扑的进程数量和线程数量等

# 重新配置拓扑
# "mytopology" 拓扑使用5个Worker进程
# "blue-spout" Spout使用3个Executor
# "yellow-bolt" Bolt使用10个Executor

storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10

注:"mytopology"是拓扑的名称,"blue-spout"和"yellow-bolt"是组件的名称。

14.remoteconfvalue

打印出远程集群Storm配置的conf-name的值。语法如下:

storm remoteconfvalue conf-name

注:集群Storm配置是$STORM-PATH/conf/storm.yaml与defaults.yaml合并的结果。该命令必须在集群节点上运行。

15.supervisor (常用!)

启动Supervisor守护进程。语法如下:

storm supervisor

注:该命令应该使用daemontools或者monit工具监控运行。

16.ui (常用!)

启动UI守护进程。语法如下:

storm ui

注:UI为Storm集群提供了一个Web界面并显示运行拓扑的详细统计信息。该命令应该使用daemontools或者monit工具监控运行。

17.version

打印Storm发布的版本号。语法如下:

storm version

 

© 著作权归作者所有

粉丝 47
博文 533
码字总数 244932
作品 0
海淀
私信 提问
Apache Storm 0.9.6/0.10.0 发布

Apache Storm 0.10.0 发布,此版本是个稳定版本,相比之前的 Beta 版本主要包括 bug 修复和改进: STORM-1108: Fix NPE in simulated time STORM-1106: Netty should not limit attempts to...

oschina
2015/11/06
4.7K
8
storm启动卡着不动,求高手

刚把storm集群部好,结果启动时卡着不动。 执行:./storm nimbus 提示: [root@WY_CentOS_100G bin]# ./storm nimbus Running: java -server -Dstorm.options= -Dstorm.home=/usr/local/src......

lja
2013/07/11
2.2K
1
Apache Slider + Storm

Apache Slider + Storm 系统环境 安装如下组件,部署可用环境 JDK 1.7.0_79 Apache Zookeeper 3.4.* Apache Zookeeper Apache Hadoop 2.6.* Apache Hadoop Apache Storm 0.9.4 Apache Storm......

Yulong_
2016/09/21
416
0
storm client command

最近在研究实时日志分析,storm确实不错,以下是命令参数: storm help Syntax: storm jar topology-jar-path class 运行jar包中类的主函数和指定的参数 Commands: activate storm activate ...

China_OS
2014/02/22
1K
0
windows 安装 storm 及 eclipse 调试 TopN 实例

一:安装JDK 下载地址:地址一 地址二 配置Java环境变量 JAVAHOME、Path、CLASSPATH三个值分别为(按照自己安装状况设置,此处供参考): D:javajdk1.8 %JAVAHOME%/bin;%JAVAHOME%/jre/bin ....

大数据之路
2012/06/08
354
1

没有更多内容

加载失败,请刷新页面

加载更多

Spring Boot + Mybatis-Plus 集成与使用(二)

前言: 本章节介绍MyBatis-Puls的CRUD使用。在开始之前,先简单讲解下上章节关于Spring Boot是如何自动配置MyBatis-Plus。 一、自动配置 当Spring Boot应用从主方法main()启动后,首先加载S...

伴学编程
昨天
7
0
用最通俗的方法讲spring [一] ──── AOP

@[TOC](用最通俗的方法讲spring [一] ──── AOP) 写这个系列的目的(可以跳过不看) 自己写这个系列的目的,是因为自己是个比较笨的人,我曾一度怀疑自己的智商不适合干编程这个行业.因为在我...

小贼贼子
昨天
7
0
Flutter系列之在 macOS 上安装和配置 Flutter 开发环境

本文为Flutter开发环境在macOS下安装全过程: 一、系统配置要求 想要安装并运行 Flutter,你的开发环境需要最低满足以下要求: 操作系统:macOS(64位) 磁盘空间:700 MB(不包含 IDE 或其余...

過愙
昨天
6
0
OSChina 周六乱弹 —— 早上儿子问我他是怎么来的

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @凉小生 :#今日歌曲推荐# 少点戾气,愿你和这个世界温柔以待。中岛美嘉的单曲《僕が死のうと思ったのは (曾经我也想过一了百了)》 《僕が死の...

小小编辑
昨天
2.7K
16
Excption与Error包结构,OOM 你遇到过哪些情况,SOF 你遇到过哪些情况

Throwable 是 Java 中所有错误与异常的超类,Throwable 包含两个子类,Error 与 Exception 。用于指示发生了异常情况。 Java 抛出的 Throwable 可以分成三种类型。 被检查异常(checked Exc...

Garphy
昨天
42
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部