用户组:游客
提交topology成功后,发现运行不正常 [*]验证topology提交成功:打开nimbus ui,看看提交的topology是否存在 [*]检查自己的top ...
很奇怪的问题,具体现象就是启动了多个supervisor,单在ui上只显示一个(也有可能是多个supervisor中的某几个看上去被“合并”了 ...
在一个bolt里做uv去重,而且这个bolt是并发的,重复的uv应该存到内存map还是类似与redies的缓存啊。还有在对redies操作的时候 ...
疑问: 在给SpoutConfig 传递第三个参数zkroot时,这个zkroot的路径是怎么确定的,我在storm配置文件中配置zk时,只配置了 [mw_shl_ ...
启动storm的拓扑时报了这个异常: 2016-05-31T19:49:24.749+0800 b.s.d.worker [ERROR] Error on initialization of server mk- ...
kafka_2.10 strom-0.9.6 因为下载的storm/external里面有storm-kafka的jar包所以直接用的这个。 但是在运行的时候会报错: j ...
问题导读: 1.Storm有哪几种消息保证机制?2.如何实现可靠的 Bolt?3.Trident 中,Spout 和 State 分别有哪几种状态? ...
Storn可以设置动态的时间滑动窗口吗?可以的话怎样写?
TridentTopology tridentTopology = new TridentTopology(); Stream stream = tridentTopology.newStream("event", kafkaSpout) ...
这个是什么错误,在安装集群的时候?????在线等
问题导读1.持久化操作带来的难点是什么?2.Storm处理事务性应用时是怎样来接收和处理数据的? 接触流计算领 ...
操作系统:contos6.5软件包如下: 机器环境:主节点:192.168.23.208 bigdata-208 软件安装位置/cloud 安装步骤一:安装jerom ...
storm这个异常怎么解决,每天出现1~2次
本版积分规则 发表帖子
查看 »