求指教

Hentai 2016-10-12 2 6454

kafka、storm与hdfs整合，将topology在storm运行后，运行正常。查看ui、nimbus、supervisor、worker.log文件都没报错。没有将数 ...

百事 2016-8-26 2 5197

https://basebase.github.io/2016/08/11/storm%E6%95%B4%E5%90%88kafka%E9%87%8D%E5%A4%8D%E6%B6%88%E8%B4%B9%E9%97%AE%E9%A2%98 ...

Joker 2016-8-12 3 13017

defaultScheduler会在为topology分配任务之前释放掉其他topology不再需要的资源，即bad slots，哪位大神能否讲什么情况下会出现t ...

louiscool2 2016-7-31 3 10756

storm1.0.1安装完成以后，配置storm-yaml.xml，以下三项已修改： storm.zookeeper.servers: - "yun01-nn-02" - "yu ...

xw2016 2016-7-17 3 15115

kafka_2.10 strom-0.9.6 因为下载的storm/external里面有storm-kafka的jar包所以直接用的这个。 但是在运行的时候会报错： j ...

alu1105 2016-7-5 1 7551

这个问题一直困扰了我许久！我的spout 运行到某个时间，Acked 处理的tuple数就不增加了，也就没有处理tuple了，但是spout Emitte ...

一个好人 2016-6-27 6 13721

从UI上看,SPOUT上的正常的消息数没有变化,失败的消息一直在增加 程序一直在正常运行中 在代码方面由于每个execute都是使 ...

qyd100 2015-4-16 3 26140

我的spout数据源是来自消息队列kafka，然后发射出去给bolt处理。一般我们可能会遇到spout Failed的情况，但是我有个疑惑：为何我 ...

一个好人 2016-6-24 2 7971

启动storm的拓扑时报了这个异常： 2016-05-31T19:49:24.749+0800 b.s.d.worker [ERROR] Error on initialization of server mk- ...

rambo_js1019 2016-5-31 1 8681

疑问: 在给SpoutConfig 传递第三个参数zkroot时,这个zkroot的路径是怎么确定的,我在storm配置文件中配置zk时,只配置了 [mw_shl_ ...

ltz 2016-5-30 1 6451

在运用kafka+storm进行日志分析时，发生kafka消息堆积，在storm的worker日志里面看到如下异常日志，完全跟自己的业务代码无关， ...

rambo_js1019 2016-5-25 2 8917

torm打jar，我把自定义配置文件打在jar包的外面，提交到集群上之后，这个配置文件应该放在集群的什么位置啊？

liu6182169 2016-5-23 5 5514

[root@linux5 bin]# storm nimbus Traceback (most recent call last): File "/export/servers/storm/bin/storm", line 51 ...

zuodev 2016-5-21 3 11596

RT，执行上传命令的时候，报错，希望帮忙看看是哪的问题，谢谢啦！！

lwq 2016-5-7 7 9078

RT，按照网上的配置配置好后，执行 storm nimbus，报图中的错误，不知道如何解决，恳请大家帮忙看看是哪里的原因，万分感谢~ ...

lwq 2016-4-26 2 5641

我的问题已经在标题中描述出来了，下面我详细的描述下我的问题。看了storm，知道他用nimbus\zk\supervisor通过主从结构来搭建集 ...

pengsuyun 2016-3-31 2 7809

在网上找了个例子，是storm通过从数组中随机取字符串写入操作系统文本的，我打包后在集群环境跑了一下，一切正常。 在这个基 ...

lihy114 2016-3-28 5 10536

运行storm jar的时候会报java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy这个错误 我的pom里面有这个jar包 ...

Jame 2015-9-22 4 11077

storm运行时bolt报异常，也不是经常出现这个异常，我查了下网上的解释：这个信息表示你在将一个可变的对象作为 tuple 发送出去。 ...

hai3wei 2016-3-6 3 11418

本人storm初学者，用阿里的jstorm。 zookeeper能正常启动运行，并能用zkCli.sh联上。 但jstorm nimbus报了错, 如下： [mw_s ...

homeryan 2016-2-19 3 17616

目前情况是这样的： 我们现在实时数据处理用的是storm+ssdb+mysql。 在做实时处理的时候避免不了会有一些缓存数据存到ssdb，ss ...

mjjian0 2016-2-18 4 15761

发现日志文件里不停的在打下面的日志，一秒有几十条，这是什么情况啊？哪位帮忙看看 2016-01-12 13:07:44.265 o.a.h.h.z.Reco ...

hai3wei 2016-1-12 2 7530

supervisor节点上log目录下日志文件 tail -f work-6703.log 2016-01-23T07:48:00.448+0800 s.k.KafkaUtils Task [2/6] assi ...

szcountryboy 2016-1-23 5 15206

storm如何关闭Ack机制

NEOGX 2014-12-4 4 36254

想请教一下，storm如何从日志中统计过去十分钟内同一ip的个数？

leegh1992 2016-1-6 3 9091

背景：我在远程的Linux服务器上安装了kafka，Linux上测试可以发送和接收消息，本地idea上本地模式运行storm，获取远程Linux上kaf ...

隔壁老王啪啪啪 2015-11-4 3 29100

如题，Storm并行度与kafka分区数是否有关系呢？ BrokerHosts brokerHosts = new ZkHosts(zkConnString); SpoutConfig spoutCon ...

szcountryboy 2015-12-22 3 9414

请问哪位大神指导如何解决该问题： 我定义了个topology，spout是负责读取文件后，转为消息流emit出去的。但现在有个烦恼的 ...

caiyifeng 2015-11-16 3 8142