加载中
storm rest api

storm rest api返回的是json。我们可以查询,configuration,nimbus,supervisor,cluster的summary信息。也可以直接操作拓扑,启动,干掉等。 请求前缀: http://<ui-host>:<ui-port>/api/v...

2017/04/05 09:45
59
storm命令行

1.activate 激活指定的拓扑。语法如下: storm activate topology-name 2.classpath 打印出Storm客户端运行命令时使用的类路径(classpath)。语法如下: storm classpath 3.deactivate 暂停指...

2017/03/27 11:36
37
storm启动supervisor后自动退出问题

如果启动后,supervisor自己退出,应该与Storm.local.dir设定的目录有关。 如果目录不存在的话,启动后会自动退出。 如果关闭再重新启动storm时,有时也会出现这样的情况。。 如果仍有退出发...

2017/03/14 11:17
117
storm kafka出现错误或fail后,是否继续处理数据?

在可靠性Topology中,storm消费kafka中的数据,当storm ui中出现错误或fail的时候,以后的数据会继续通过Topology被处理完成,但是此时zk中的出现问题的partition的offset是不变的(保留在出...

2017/03/13 16:57
40
storm supervisor挂掉错误

错误日志: 2017-03-13T15:25:32.925+0800 o.a.z.ClientCnxn [WARN] Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect java.net.Connec...

2017/03/13 15:54
80
storm、hbase、kafka整合过程中遇到的log4j冲突问题

storm、hbase、kafka整合过程中遇到的log4j冲突问题 ---》报错 SLF4J: Detected both log4j-over-slf4j.jar AND slf4j-log4j12.jar on the class path, preempting StackOverflowError. SLF4...

2017/02/24 17:56
100
关于storm的topology启动时间过长(端口占用)如何解决

storm版本是0.9.4 ,当storm集群上任务比较多的时候,启动一个topology,要过5-10分钟或者更久才能启动起来。 worker log报错如下: 2016-03-21T09:58:31.217+0800 b.s.m.n.Client [ERROR] c...

2017/02/22 15:36
113
storm trident

简介 Storm是一个实时流计算框架,Trident是对storm的一个更高层次的抽象,Trident最大的特点以batch的形式处理stream。 一些最基本的操作函数有Filter、Function,Filter可以过滤掉tuple,F...

2016/12/20 20:44
93
storm 提高运行速度

(1)要将系统中的算法调优。有可能一个算法浪费了一小部分时间,但由于数据量可能比较大,以至于整体上1秒的时间内可能浪费大量的时间。因此,算法的设计还是比较重要的。 (2)其次,就是调...

2016/12/19 11:08
98
storm ui指标说明

1.Storm ui 首页 主要分为4块: Cluster Summary,Topology summary,Supervisor summary,Nimbus Configuration,如下图所示: Cluster Summary Version: storm 版本号 Nimbus uptime: nimbu...

2016/12/19 10:03
120
storm 可靠性和非可靠性

我们知道Storm有一个很重要的特性,那就是Storm API能够保证它的一个Tuple能够被完全处理,这一点尤为重要,其实storm中的可靠性是由spout和bolt组件共同完成的,下面就从spout和bolt两个方便...

2016/12/16 16:48
71
storm bolt重复消费的问题

storm bolt重复消费的问题

2016/08/16 09:23
150
storm配置参数详解

storm配置参数详解

2016/02/04 16:28
1K
storm拓扑的并行度(parallelism)概念

storm拓扑的并行度(parallelism)概念

2016/02/02 18:53
985
storm集群WordCount实例

storm集群WordCount实例

2016/02/02 12:36
531
windows下storm本地模式java开发实例

windows下storm本地模式java开发实例

storm java 编程思路

storm java 编程思路

2016/01/27 19:22
256
storm spout和bolt java api

storm spout和bolt java api

2016/01/27 17:13
191
storm集群搭建

storm集群搭建

2016/01/27 14:26
325
storm可靠机制

storm可靠机制

2016/01/26 15:30
157

没有更多内容

加载失败,请刷新页面

返回顶部
顶部