用户组:游客
目前情况是这样的: 我们现在实时数据处理用的是storm+ssdb+mysql。 在做实时处理的时候避免不了会有一些缓存数据存到ssdb,ss ...
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/thrift7/TBase at java.lang.ClassLoader.defineCla ...
目前,遇到一个棘手的问题,storm集群运行过程中,出现数据不处理情况。 架构是kafka-storm-db 当db服务器宕机后,storm由于部 ...
运行storm jar的时候会报java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy这个错误 我的pom里面有这个jar包 ...
Strom on yarn 集群已经部署好了,ui界面也没有问题,在提交Strom的拓扑时,拓扑在本地模式下已经通过没有任何问题,提交到集群 ...
storm如何关闭Ack机制
如图: [root@master blobs]# jps 8817 Jps 7930 nimbus 8076 core 3667 SecondaryNameNode 3480 NameNode 7626 Quor ...
autoconf版本是2.68,automake1.11,libtool版本是2.4.2
defaultScheduler会在为topology分配任务之前释放掉其他topology不再需要的资源,即bad slots,哪位大神能否讲什么情况下会出现t ...
想请教一下,storm如何从日志中统计过去十分钟内同一ip的个数?
storm运行时bolt报异常,也不是经常出现这个异常,我查了下网上的解释:这个信息表示你在将一个可变的对象作为 tuple 发送出去。 ...
最近想开始学习hadoop,但不知道怎么开始学习,有大师指教一下,怎么配置个人环境。
org.apache.atlas.notification.NotificationException: java.util.concurrent.ExecutionException: org.apache.kafka.common.er ...
storm1.0.1安装完成以后,配置storm-yaml.xml,以下三项已修改: storm.zookeeper.servers: - "yun01-nn-02" - "yu ...
请问哪位大神指导如何解决该问题: 我定义了个topology,spout是负责读取文件后,转为消息流emit出去的。但现在有个烦恼的 ...
为什么启动superviosr时,启动成功之后,过2、3秒钟就提示Kill No Such process,然后superviosr就死掉了??
Spout设置成多线程有什么用? 读取一个文件中的内容,如果spout并行度设置2的话不就是读取两遍吗 那允许spout设置并行度有什么 ...
SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "mykafka", "mytop1"); TopologyBuilder builder = new TopologyB ...
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 ...
我在storm平台发布了一个Topology(例如 testTopology),通过kafkaSpout 从kafka上抓取消息进行处理; storm会在 zookeeper的节 ...
我在对一些数据做统计,用到redies,把统计结果放在redies中,然后下一个tuple来了从redies中取出来然后在做统计,统计后在放到r ...
环境信息 s1 nimbus s2 supervisor s3 supervisor s4 supervisor storm提交两个拓扑,tp1,tp2,每 ...
storm-kafka用的是0.10.0 这个版本里面找不到SpoutConfig.forceFromStart 这个配置项 需要怎么设置storm读取kafka中新消息,而 ...
本人storm初学者,用阿里的jstorm。 zookeeper能正常启动运行,并能用zkCli.sh联上。 但jstorm nimbus报了错, 如下: [mw_s ...
在搭建Storm的时候,都会说搭建zookeeper这里并不是很了解 我只知道zookeeper作为一个协调框架,只要向ZK里面输入信息,其他 ...
我在使用storm过程中,经常有几点会报一下错误: 2015-07-29T16:35:28.719+0800 b.s.m.n.Client [ERROR] connection attempt 52 ...
平时我们发布Topology,都是在后台用 ./jstorm jar xxxxx.jar com.xxxx.xxxTopolog arg0,arg1 来将Topology发布到storm上 现 ...
背景:我在远程的Linux服务器上安装了kafka,Linux上测试可以发送和接收消息,本地idea上本地模式运行storm,获取远程Linux上kaf ...
运行wordcountTopology出现异常,截图如附件,求大神指导
1. 我在PC服务器上装了3台虚拟机,配置了3个storm集群节点,配置storm.yaml ,slot配置了10个端口 26700------26709 2. 我发布 ...
本版积分规则 发表帖子
查看 »