SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "mykafka", "mytop1"); TopologyBuilder builder = new TopologyB ...

aboutzzz 2014-10-22 3 27041

在一个bolt里做uv去重，而且这个bolt是并发的，重复的uv应该存到内存map还是类似与redies的缓存啊。还有在对redies操作的时候 ...

mjjian0 2015-11-10 1 9104

如图 这个是什么错误？

Jame 2015-9-11 6 9670

请问哪位大神实际用过cgroup进行storm的资源隔离啊，求教！！！

caiyifeng 2015-10-30 2 14477

求资料分享，买了几本书十几分钟就看完了啥有用的都没有

邓立辉 2015-10-26 2 9003

由于怕系统太繁忙而导致消息处理不及时,所以storm设置了一个超时时间比较长 conf.setMessageTimeoutSecs(300); 当设置这个以 ...

qyd100 2015-4-17 2 18336

平时我们发布Topology，都是在后台用 ./jstorm jar xxxxx.jar com.xxxx.xxxTopolog arg0,arg1 来将Topology发布到storm上 现 ...

caiyifeng 2015-10-24 3 12271

今天Jstorm生产环境遇到了让人崩溃的问题！！ 今天我们Jstorm集群加了两台新机器，部署没什么问题，supervisor都正常启动，Topo ...

caiyifeng 2015-10-22 4 9331

在执行storm过程中出现如下的异常，虽然不影响结果，但是还是求教为什么会出现这样的异常，该怎么解决呢？ 9782 [Thread-6-Send ...

haorengoodman 2014-12-17 17 103396

请问，用trident时，做groupby的时候，数据多了就不执行了，日志也没报错，尝试修改配置文件中相关的buff、size相关的配置也不行 ...

邓立辉 2015-10-20 3 8424

我发布了一个Topology，通过Storm UI界面观察，发布成功，但却无法显示spout,bolt等相关信息，看下图， 但奇怪的是我观察后台的 ...

caiyifeng 2015-4-12 6 16482

很奇怪的问题，具体现象就是启动了多个supervisor，单在ui上只显示一个（也有可能是多个supervisor中的某几个看上去被“合并”了 ...

jixianqiuxue 2015-4-16 1 19682

最近在做项目，有些业务复杂点的 用简单的 topology 感觉实现起来有点牵强。所以就研究研究trident，然后看到了流合并 merge和jo ...

mjjian0 2015-6-6 5 22345

最近想开始学习hadoop,但不知道怎么开始学习，有大师指教一下，怎么配置个人环境。

sh_aland 2015-10-1 3 8634

1.我用Storm单机模式运行，没有启动zookeeper、Nimbus、Supervisor，直接在终端输入命令： ./storm jar /home/chimes/workspace ...

chimes298 2015-9-26 4 30802

storm的supervisor里面的work-60*.log被删掉了 运行jar包就报下图的错误 重启storm和zookeeper后还是报错 求帮忙 ...

Jame 2015-9-21 6 9698

storm启动不了了 supervisor 日志报错如下

Jame 2015-9-23 2 8446

提交topology成功后，发现运行不正常 [*]验证topology提交成功：打开nimbus ui，看看提交的topology是否存在 [*]检查自己的top ...

hyj 2015-9-21 1 8354

我在做storm集成kafka的时候maven里面有curator-recipes这个包为什么还是会报这个错误， 谁遇见过这个错误， 或者知道 ...

Jame 2015-9-14 6 10750

我根据这个例子来整合kafka flume storm但是会报这个错误球大神帮我解决下

Jame 2015-9-10 8 10652

操作系统：contos6.5软件包如下： 机器环境：主节点：192.168.23.208 bigdata-208 软件安装位置/cloud 安装步骤一：安装jerom ...

anita 2015-9-8 0 7217

1.概述 通过前面的介绍,我们知道Storm可以实现弹性计算,根据需要实时调整Topology的并行度. 参考: 1)翻译：Storm Sca ...

xuanxufeng 2015-9-3 1 9804

我在storm平台发布了一个Topology（例如 testTopology）,通过kafkaSpout 从kafka上抓取消息进行处理； storm会在 zookeeper的节 ...

caiyifeng 2015-8-26 3 11375

本帖最后由 tntzbzc 于 2015-8-19 19:39 编辑 2015-08-19 15:39:30 b.s.d.nimbus [ERROR] Error on initialization of server ...

tntzbzc 2015-8-19 2 20633

我现在有两个Topology,想消费同一个 topic，请问我需要设置什么参数吗？

caiyifeng 2015-8-7 14 32672

求教各位： 我有一个topic，两个Topology，都需要消费该topic的数据，好像需要设置不同的consumer group才能支持， 请问程序 ...

caiyifeng 2015-8-12 4 39533

我在用本地模式调试的时候在bolt中能读取到数据 而使用StormSubmitter.submitTopology的时候 storm jar运行我的打包程序 执行 ...

zou79189747 2015-8-4 8 25015

在浏览器中打开Storm UI 的页面监控，发现运行的Storm Topology 报有若干错误，但是错误提示的颜色不一样，请问这是不是Storm内 ...

hapjin 2015-8-3 2 11518

在运行storm时候，经常有的supervisor节点总会报java.lang.OutOfMemoryError: PermGen space 我想增大PermGen space 的大小， ...

caiyifeng 2015-7-30 2 14086