用户组:游客
storm的supervisor里面的work-60*.log被删掉了 运行jar包就报下图的错误 重启storm和zookeeper后还是报错 求帮忙 ...
各位大能请教个问题:我以前storm supervisor是3个节点,zookeeper也是三个,ui也正常显示三个supervisor。但是后来又加进来4个 ...
我发布了一个Topology,通过Storm UI界面观察,发布成功,但却无法显示spout,bolt等相关信息,看下图, 但奇怪的是我观察后台的 ...
大神们,有个问题咨询下大家设计完拓扑后,bolt的executors和tasks数应该如何设计? 测试发现有的bolt是在20能达到最佳速度,有 ...
各位大虾: 现有如下问题,求助各位。 storm的worker数量应该按照什么规则去创建。是按照CPU核数创建?比如storm为8核,就定义 ...
有storm相关的视频可以下载的吗? 各位大神知道哪里有storm视频资源可以下载吗?
工程结构如下,我没有用maven来构建工程 高手们问个问题,刚接触storm,我在windows环境下用myeclipse构建了一个storm的dem ...
想使用assembly打包,一直提示找不到编写的类,请求高手指点一下啊
这个问题一直困扰了我许久!我的spout 运行到某个时间,Acked 处理的tuple数就不增加了,也就没有处理tuple了,但是spout Emitte ...
写了一个Topology,需要进行跟踪,请问有哪位大虾知道下面的问题: 我在spout 中 emit了一个消息,带有messageId的,如 emit(Lis ...
问一下,我的spout有一批数据,这批数据都有一个标记位,值分别为A、B、C,我想把标记位值为A的数据发送到A_Bolt,值为B的发送到 ...
问个问题,就是三台集群的storm,在工作时只有其中一台的storm supervsior 的work在工作 ,另外一台的机器的supervisor 没有接受 ...
在网上找了个例子,是storm通过从数组中随机取字符串写入操作系统文本的,我打包后在集群环境跑了一下,一切正常。 在这个基 ...
请教些问题: 本人现在在着手写实时计算方面的论文,现在思路还是有点乱, (1) 关于实时计算有哪些算法可以去研究下; ...
7532 [Thread-16-spout-executor[3 3]] INFO o.a.s.k.ZkCoordinator - Task [1/1] Refreshing partition manager connections ...
在Eclipse中运行Storm程序,第一次是完全成功的,但是在运行第二次 报了错误,
刚才发了帖子咨询storm总是会莫名shutdown 刚才发现kafka也是,白天都正常运行,第二天过来看,总是会shutdown 我查了日志信 ...
我想统计在每分钟内,出现次数最多的10个ip
supervisor节点上log目录下日志文件 tail -f work-6703.log 2016-01-23T07:48:00.448+0800 s.k.KafkaUtils Task [2/6] assi ...
来自群友整理之: storm,所有的bolt都没抛异常,但spout就有failed的。。。求解。。。 原因: 超时 默认的超时时间 ...
Storm中的Spout设置并行度为4 读取同一个文件,会不会读取这个文件的四份啊
torm打jar,我把自定义配置文件打在jar包的外面,提交到集群上之后,这个配置文件应该放在集群的什么位置啊?
最近在做项目,有些业务复杂点的 用简单的 topology 感觉实现起来有点牵强。所以就研究研究trident,然后看到了流合并 merge和jo ...
我调用的是kafkaSpout 从kafka取消息,请问能否得到 每秒从kafka获取的消息数量,我知道storm有个registerMetric,CountMetric() ...
在storm中,可以支持一些比较复杂的算么?比如处理图片的算法
今天Jstorm生产环境遇到了让人崩溃的问题!! 今天我们Jstorm集群加了两台新机器,部署没什么问题,supervisor都正常启动,Topo ...
autoconf版本是2.68,automake1.11,libtool版本是2.4.2
如图: [root@master blobs]# jps 8817 Jps 7930 nimbus 8076 core 3667 SecondaryNameNode 3480 NameNode 7626 Quor ...
求教各位: 我有一个topic,两个Topology,都需要消费该topic的数据,好像需要设置不同的consumer group才能支持, 请问程序 ...
目前情况是这样的: 我们现在实时数据处理用的是storm+ssdb+mysql。 在做实时处理的时候避免不了会有一些缓存数据存到ssdb,ss ...
本版积分规则 发表帖子
查看 »