storm程序kill是出现错误，storm kill不掉运行的Topology
Topology 的持久化状态包括： active, inactive, killed, rebalancing 四个状态。
代码上看到每种状态都可以转换成一些持久化 ( 写入到 zk 中的状态 ) 或者中间状态。
我们在shell上的操作实际上就是改变的zookeeper数据存储的程序状态，出错直接清空zookeeper目录即可
详细文章见：http://lbxc.iteye.com/blog/1530254
liyonghui160com
- 浏览: 774583 次
- 性别:
- 来自: 北京
-
最新评论
-
liyonghui160com：
RAYFUXK 写道您好，我最近也在使用Canal，但是遇到了 ...
canal使用配置详解 -
xinglianxlxl：
订阅发布对我有用
redis-2.8.13 jedis实现订阅发布-publish/subscribe -
liyonghui160com：
这个不能按照一条一条的读取数据。使用需要完善。
flume文件监控的source，支持断点续传功能 -
RAYFUXK：
您好，我最近也在使用Canal，但是遇到了一个问题。ERROR ...
canal使用配置详解 -
yicong：
非常感谢！发现github里面的log4net版本太 ...
Zookeeper .Net客户端代码
相关推荐
使用`storm kill`命令可以停止一个正在运行的拓扑： ```bash storm kill my_topology ``` 然后重新提交更新后的jar文件即可。 总结，Apache Storm 1.2.1单机部署涉及以下步骤：安装JDK、下载并解压Storm、配置...
标题中的“storm实例，可以直接运行”表明这是一个关于Apache Storm的实际应用案例，Apache Storm是一个开源的分布式实时计算系统，常用于处理大规模数据流。这个实例可能是为了演示如何在Storm集群上部署和运行一个...
【标题】"storm提交topology的过程"涉及到的是Apache Storm这一分布式实时计算系统中的核心操作——部署和运行流处理任务，即topology。Apache Storm被广泛应用于实时数据处理、在线机器学习、持续计算以及大规模...
STORM的TOPOLOGY在线上运行时，随着数据量的增加，在一定的服务器性能及集群规模下，会渐渐达到一个极限，到达极限后，服务器的load、io、cpu、mem等可能会出现耗尽，系统很卡，storm吞吐量骤降的情况。本文档中截图...
在集群上运行时，Storm会自动将topology分配到可用的工作节点上，并根据拓扑定义进行数据处理。为了监控topology的状态，可以使用Storm UI，它是一个基于Web的界面，可通过集群的Nimbus节点的指定端口访问（默认为...
1. **Storm/workerbeats/<topology-id>/node-port**：存储 Worker 的运行状态和统计信息，包括 topology-id、Worker 上所有 Executor 的统计信息（例如发送和接收的消息数）、Worker 的启动时间和最后更新时间等。...
Storm作为开源的分布式实时计算系统在业界得到了广泛应用，针对Storm自带调度策略忽略了Topology组件任务间的逻辑耦合性，从而引起大量tuple传输产生较大网络时延问题，结合进程代数将Topology等效简化为具有明显...
Storm的基本单位是“topology”（拓扑结构），它可以理解为一个实时计算的网络图，包含spouts和bolts两个主要组件。 Spout是拓扑中的数据源组件，主要负责从外部数据源如文件、数据库或者消息队列中获取原始数据，...
9. **监控和管理**：通过Storm UI监控拓扑运行情况，如有异常，可使用`storm kill`命令停止拓扑，或`storm list`查看当前运行的拓扑。 集群搭建完成后，需要注意监控集群的健康状况，包括资源利用率、网络延迟、...
使用`bin/storm kill`命令可以停止正在运行的拓扑。 7. **日志和监控**：Storm的日志通常存储在Supervisor节点的工作目录下，可以配置日志级别和日志输出。同时，为了生产环境的稳定，推荐使用如Logstash、Fluentd...
大家都知道，要提交StormTopology到Cluster，需要运行如下命令：bin目录下storm是一个Python文件，我们可以看一下Python脚本的main方法首先解析args参数，解析完了之后，把所有的参数传递给COMMANDS，由COMMANDS调用...
- **Topology**：Storm中的数据处理逻辑被封装在Topology中，它定义了数据流如何在组件之间流动。 - **Spout**：Spout是数据流的源头，负责读取外部数据并将其发送到Storm中进行处理。 - **Bolt**：Bolt是数据处理...
由于提供的信息中并没有实际的电子书内容，而仅仅是重复的广告信息和联系QQ，这导致无法生成具体的知识点。...通过掌握以上知识点，可以让Storm集群在各种企业环境中高效稳定地运行，同时快速响应各种业务需求的变化。
2. **Topology构建**：Topology是Storm的核心，它的构建方式非常灵活。通过配置文件和Java API可以方便地定义复杂的计算逻辑。 3. **消息传递机制**：Storm通过Tuple来表示数据流中的单个元素，Tuple在Spout和Bolt...
在Storm中，创建Topology后需要提交到Storm集群进行运行。在"weekend-storm"项目中，Topology的配置将决定数据如何被处理和分析。 在实际开发中，我们还需要了解以下几点： 1. **容错机制**：Storm保证即使在节点...
要测试集群，可以运行 Storm 提供的示例 Topology，例如 WordCount，通过 `storm jar` 命令提交 Topology，然后使用 `storm kill` 命令可以终止运行的 Topology。 总的来说，Strom 的强大在于其灵活的实时处理能力...
描述中的 "帮助不能下载的同学下载storm安装包" 表明这个文件是为那些无法正常下载 Apache Storm 的人提供的，可能是因为网络问题或其他原因导致的下载失败。 在标签中，"storm 安装包" 暗示了这个文件的用途，即它...