用户组:游客
发现日志文件里不停的在打下面的日志,一秒有几十条,这是什么情况啊?哪位帮忙看看 2016-01-12 13:07:44.265 o.a.h.h.z.Reco ...
我的问题已经在标题中描述出来了,下面我详细的描述下我的问题。看了storm,知道他用nimbus\zk\supervisor通过主从结构来搭建集 ...
RT,按照网上的配置配置好后,执行 storm nimbus,报图中的错误,不知道如何解决,恳请大家帮忙看看是哪里的原因,万分感谢~ ...
在运用kafka+storm进行日志分析时,发生kafka消息堆积,在storm的worker日志里面看到如下异常日志,完全跟自己的业务代码无关, ...
我的spout数据源是来自消息队列kafka,然后发射出去给bolt处理。一般我们可能会遇到spout Failed的情况,但是我有个疑惑:为何我 ...
kafka、storm与hdfs整合,将topology在storm运行后,运行正常。查看ui、nimbus、supervisor、worker.log文件都没报错。没有将数 ...
求指教
1个worker进程执行的是1个topology的子集(注:不会出现1个worker为多个topology服务)。1个worker进程会启动1个或多个executor ...
最近在学习storm,需求是实时接收5万辆车子上的GPS数据,原来的想法是:服务器开启一个socket监听,GPS设备通过TCP协议把数据发 ...
请教个问题: 在storm集群上提交topo时,跨机房,网络有时不稳定。 topo源文件又比较大,比如100M,supervisor从nimbus拉取要 ...
storm数据接入层,大家都用的什么方式?消息队列的话,哪些队列比较好用? Kafka, zeroQ, metaQ , ...?
spout是不是只能读流式的数据 比如从消息队列中读取 读完一条 这条数据就已经不再消息队列中了?读文件 怎么控制?
Storm 实现滑动窗口累加,怎么控制窗口滑动呢,在bolt控制的话不好掌握,特别是多线程bolt的情况下,窗口就会滑动多次,怎么解决 ...
请教一下一个bolt可以发送两次数据吗 collector.emit collector.emit 两次
本帖最后由 pig2 于 2014-10-26 16:46 编辑 谁有9.0.1.0的源代码么?
storm on yarn可以跑在Hadoop2.4.1上么,我的在storm on yarn在Hadoop2.4.1上报错,报错信息如下: java.lang.NoClassDefFoundE ...
EndOfStreamException: Unable to read additional data from client sessionid 0x14a2d366c96000b, likely client has closed s ...
有谁试过用storm直接向HDFS写数据?性能问题比较突出
请教各位高手,我定义了一个topology,是通过kafkaspout来抽取消息的,后面有2个bolt进行消息处理,请问又没办法做到: spout 发 ...
emit是应该弹送到下个bolt中,那么作为最后的bolt是否还需要emit? 看了一些书的例子,有些有,有些没有. 自己试验了一下,感觉没 ...
比如我现在的实时项目架构是:flume--》kafka---》storm---》hive 最后通过storm分析,分析后的数据落地到hive,但现在有个问题 ...
如图:在SpoutEmitter报了类不能转换的错误2015-06-02T09:31:35.083+0800 b.s.d.executor [ERROR] java.lang.RuntimeException ...
java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:30) ~[na:1.6.0_25] ...
storm 每秒消费kafka的数据 大概极限是多少条?
我程序中 spout用的是storm.kafka.KafkaSpout。 然而在运行一段时间后看ui会有失败的 有没有人遇见过这个情况啊讨论下啊 ...
提交topology成功后,发现运行不正常 [*]验证topology提交成功:打开nimbus ui,看看提交的topology是否存在 [*]检查自己的top ...
在一个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 ...
本版积分规则 发表帖子
查看 »