storm问题求助！

我在本地运行我这样设置在分布式上就出不来结果builder.setBolt("split", new SplitSentence(), 2).shuffleGrouping("clicklogspout");我这样设置结…

storm kill掉作业的时候做cleanup

如果修改了 storm 的 spout 和 bolt 代码，就 kill 掉作业，重新提交吧。那么 kill 作业的时候如何做 cleanup 的工作呢？ 我的作业是这样的：spout收…

storm中 如果spout并发度设置为2 读取同一个文件 会不会存在重复读取的问题

storm中 如果spout并发度设置为2  读取同一个文件 会不会存在重复读取的问题…

请问大家storm-hdfs这个插件怎么用？

github 下载下来是源代码，如果我要用到项目中是不是需要打成jar包？  https://github.com/apache/storm/tree/1.0.x-branch/external/storm-hdfs …

请问大家storm能直接将数据输出到elacsticsearch中吗？

请问大家storm能直接将数据输出到elacsticsearch中吗？…

STORM的 LinearDRPCTopologyBuilder 如何增加 SPOUT的并发？？

如题 STORM0.9.5的 LinearDRPCTopologyBuilder 如何增加 SPOUT的并发？？ 设置 rpc.queue.size  drpc.worker.threads 测试并发性能都没什么改观 因为D…

Kafka添加了ACL权限后，Storm该如何消费？

Kafka采用了SASL+ACL的权限验证后，Storm中的KafkaSpout该如何修改呢？ 我查看了storm-kafka-1.0.1和storm-kafka-1.1.1的源码，KafkaConfig均是使用旧…

Storm单worker到双worker的性能问题

@book 你好，想跟你请教个问题：单worker的情况下，处理消息大概是50/s，采用两个worker的时候性能没有明显的提升，根据打印的日志分析，主要的原因…

Apache Beam

@Ryan-瑞恩 你好，想跟你请教个问题： 可以在多写一点关于Apache Beam的博文吗，还有Apache  beam可以基于Storm  或者 Spark  Streaming吗…

storm 提交top、到集群以后，启动nimbus报空指针， numer错误，zookeeper

运行storm，启动失败了

#LicensedtotheApacheSoftwareFoundation(ASF)underone #ormorecontributorlicenseagreements.SeetheNOTICEfile #distributedwiththisworkforadditio…

在OpenSOC环境部署过程中，向storm提交拓扑时，报zookeeper错误信息，求助

运行 OpenSOC的示例程序 ，向storm中提交拓扑 出现如下错误log日志信息，程序不能正常运行 29246 [Thread-24-KafkaSpout] ERROR backtype.storm.util…

storm无法提交topology

在控台用storm jar 命令提交topology。执行后没提示错误，但用storm list命令和ui上查看，发现提交成功。 …

配置单机zookeeper启动服务的时候有问题如图。求解

谁能帮忙解决一下呐， 谢谢 …

storm运行到一半就不继续计算了

单机测试Storm，从rocketMq接收信息 刚刚启动的时候可以正常接收并计算数据，但是运行一段时间后就只接收数据而不计算了，求助各位大神！！ 打印Ticke…