`

storm命令

 
阅读更多

 

 

storm 命令后面可以跟很多参数,参数如下:

 

[root@h2master bin]# storm
Commands:
        activate
        classpath
        deactivate
        dev-zookeeper
        drpc
        help 命令帮助
        jar   执行上传的jar包
        kill   杀死正在执行的topology 后面跟 topology的名称
        list   查看运行的所有topology运行情况
        localconfvalue
        logviewer   启动topology日志
        nimbus      启动nimbus
        rebalance   shell方式下修改topology运行参数比如worker个数 task个数等
        remoteconfvalue
        repl
        shell
        supervisor  启动supervisor
        ui              启动topology ui界面
        version   

Help: 
        help 
        help <command>

 

 

 

集群中使用命令样子如下:

   

[root@h2master bin]# storm list

 

1379 [main] INFO  backtype.storm.thrift - Connecting to Nimbus at h2master:6627
Topology_name        Status     Num_tasks  Num_workers  Uptime_secs
-------------------------------------------------------------------
MyLocalStormTopology ACTIVE     3          1            15   

 

 

分享到:
评论

相关推荐

    Storm32 BGC 串口通信协议

    3. Mavlink Commands:这组命令是“真正的”MAVLink协议命令,并加以扩展以更好地支持STorM32的功能。当激活MAVLink心跳后,UART接口只接收MAVLink命令,蓝牙可能就无法使用了(尽管USB仍然可以接受所有命令)。 在...

    storm开发jar包以及storm例子源码

    5. **提交拓扑**:将jar包上传到Storm集群,然后使用`storm jar`命令提交拓扑。例如,`storm jar my-storm-topology.jar com.exampleTopology.WordCountTopology`会启动名为WordCountTopology的拓扑。 描述中提到的...

    apache-storm-2.4.0.tar.gz

    6. 开发拓扑(Topology)并部署到集群,这通常涉及编写 Java 或者 Clojure 代码,然后使用 `bin/storm jar` 命令提交。 在使用 Storm 进行实时数据处理时,开发者需要理解以下几个核心概念: - **拓扑(Topology)*...

    storm的jar包

    在实际使用中,开发人员会创建自定义的Storm拓扑(Topology),定义数据流的处理逻辑,然后使用`storm jar`命令提交这个拓扑到Storm集群上运行。这个过程可能涉及到编写Bolt(处理数据的组件)和Spout(产生数据的源...

    Storm API实现词频统计

    完成代码编写后,我们需要构建项目为可执行的JAR包,这在Maven项目中通常通过`mvn package`命令实现。生成的JAR文件(如`storm_demo.jar`)可以用Storm的命令行工具提交到本地或远程的Storm集群上运行,例如`storm ...

    Flume+kafka+Storm整合

    ### Flume+kafka+Storm整合知识点详解 #### 一、Flume、Kafka与Storm概述 在大数据领域,数据采集、传输与实时处理是至关重要的环节。本篇内容重点介绍了如何利用Flume、Kafka与Storm这三个开源工具实现一套完整的...

    storm_jars.zip

    例如,使用`storm jar`命令,将包含拓扑定义的JAR文件上传到Nimbus,从而启动数据处理。 总的来说,“storm_jars.zip”是Storm开发的必备资源,它为开发者提供了便捷的一站式解决方案,简化了开发环境的搭建过程。...

    storm0.9.0 linux安装包

    5. **部署拓扑**:一旦集群运行起来,你可以使用`bin/storm jar`命令提交你的拓扑到集群。这个命令需要指定包含拓扑的JAR文件路径以及拓扑类名。 6. **监控和管理**:通过Storm UI(默认在本地8080端口运行)可以...

    storm0.9.0jar包

    最后,使用`storm jar`命令提交你的应用到集群,开始处理实时数据流。 总的来说,storm0.9.0jar包是Apache Storm的一个关键组成部分,对于理解和开发实时流处理应用程序至关重要。通过深入学习Storm的架构、API和...

    storm部署(包括所有依赖rpm包、集群搭建详解)

    9. **监控和管理**:通过Storm UI监控拓扑运行情况,如有异常,可使用`storm kill`命令停止拓扑,或`storm list`查看当前运行的拓扑。 集群搭建完成后,需要注意监控集群的健康状况,包括资源利用率、网络延迟、...

    storm安装包

    7. **提交Topology**:编写好你的Storm Topology后,使用`storm jar`命令提交到集群。 ```bash storm jar your_topology.jar your.package.YourTopologyName ``` 8. **监控和管理**:Storm提供了一个Web UI,...

    storm与spark简介

    - 使用命令 `storm nimbus` 启动。 - **UI**: 提供了一个图形化界面,方便用户查看集群状态、任务执行情况等信息。 - 使用命令 `storm ui` 启动。 - **Supervisor**: 在从节点上运行,根据 Nimbus 分配的任务...

    storm入门.pdf

    书中的附录部分则提供了Storm客户端的安装指南、常用命令、Storm集群的安装与部署方法,以及如何运行书中的示例程序。 本书的翻译者提到,通过翻译这本书,他不仅希望能够帮助读者了解Storm,也希望自身的技术能力...

    storm实例,可以直接运行

    3. cmd.txt:这是一个命令脚本文件,里面应该提供了运行storm拓扑的命令行指令。用户需要根据自己的环境(包括Storm集群的地址、端口,以及可能的配置参数)修改这个脚本,特别是words111.txt的路径,然后执行脚本来...

    storm 流式处理 安装软件(包括zookeeper,jzmq,zeroMQ,storm)

    6. **验证安装**: 使用`bin/storm version`命令检查Storm是否正常运行。 **学习与实践** - 了解Storm的基本概念,如spout(数据源)、bolt(处理逻辑)、topology(拓扑结构)等。 - 掌握编写自定义spout和bolt的...

    storm组件安装部署.doc

    使用`storm jar`命令提交拓扑到集群,例如`storm jar mytopology.jar com.example.MyTopology`。 **监控和管理** Storm UI是一个Web界面,可用于查看正在运行的拓扑、worker状态和日志信息。访问`...

    storm1.1.0版本单节点部署

    在 Storm 解压目录的 bin 目录下运行以下命令: ``` ./storm nimbus & ``` 2. 启动 UI 界面,UI 提供了一个 web 界面,用于监控 Storm 集群的状态。同样在 bin 目录下: ``` ./storm ui & ``` 3. 启动 ...

    storm深入学习.pdf

    4. 安装Storm:下载Storm的源代码,使用wget命令下载,然后解压缩并安装。 二、Storm配置 Storm配置文件storm.yaml是Storm的核心配置文件,主要包括以下几个部分: 1. storm.zookeeper.servers:指定ZooKeeper...

    Storm编程实践(安装Maven-使用Maven编译运行代码-mvn 打包)

    我们需要在 storm-starter 目录中运行 mvn 命令,以便 Maven 可以查找当前目录下的 pom.xml 文件,下载所需要的依赖包。 打包代码 在编译和运行代码之后,我们需要将代码打包成 jar 包,以便将其提交到 Storm 中...

Global site tag (gtag.js) - Google Analytics