用户组:游客
Spout设置成多线程有什么用? 读取一个文件中的内容,如果spout并行度设置2的话不就是读取两遍吗 那允许spout设置并行度有什么 ...
Storm 实现滑动窗口累加,怎么控制窗口滑动呢,在bolt控制的话不好掌握,特别是多线程bolt的情况下,窗口就会滑动多次,怎么解决 ...
问一下,我的spout有一批数据,这批数据都有一个标记位,值分别为A、B、C,我想把标记位值为A的数据发送到A_Bolt,值为B的发送到 ...
storm里spout,bolt做了ack确认处理,我看ui界面,显示spout里发送失败数非常多,这个问题会是哪里出问题了? 70多万的数据就有 ...
在storm端接受kafka数据时,采用的高级的consumer api,就是通过groupid来接收kafka中的数据 如果我spout的任务开多了会不会影 ...
各位大能请教个问题:我以前storm supervisor是3个节点,zookeeper也是三个,ui也正常显示三个supervisor。但是后来又加进来4个 ...
spout是不是只能读流式的数据 比如从消息队列中读取 读完一条 这条数据就已经不再消息队列中了?读文件 怎么控制?
storm数据接入层,大家都用的什么方式?消息队列的话,哪些队列比较好用? Kafka, zeroQ, metaQ , ...?
想问一下大家 本地模式是不是本地程序直接可以跑起来? 不需要大环境? 也不需要将storm的jar包上传到服务器?
问一下:storm中,当bolt或spout任务即将宕掉的时候,做一些清理动作?
请教个问题: 在storm集群上提交topo时,跨机房,网络有时不稳定。 topo源文件又比较大,比如100M,supervisor从nimbus拉取要 ...
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/thrift7/TBase at java.lang.ClassLoader.defineCla ...
最近在学习storm,需求是实时接收5万辆车子上的GPS数据,原来的想法是:服务器开启一个socket监听,GPS设备通过TCP协议把数据发 ...
本版积分规则 发表帖子
查看 »