用户组:游客
storm这个异常怎么解决,每天出现1~2次
这个拒绝连接的错误是怎么回事?如何解决?谢谢!!
这个是什么错误,在安装集群的时候?????在线等
机器学习里面的提升(Boosting)问题在在线学习(online learning)上的应用。比如数据一个一个地到来,并通过多个弱学习器进行 ...
KafkaSpout 消费kafka的时候有设置kafka消费者组这个属性吗?有的话是哪一个属性字段?谢谢
TridentTopology tridentTopology = new TridentTopology(); Stream stream = tridentTopology.newStream("event", kafkaSpout) ...
Storn可以设置动态的时间滑动窗口吗?可以的话怎样写?
目前,遇到一个棘手的问题,storm集群运行过程中,出现数据不处理情况。 架构是kafka-storm-db 当db服务器宕机后,storm由于部 ...
这些一大堆报错,你我都不要愿意看,更不想它出现,可没有这些东西折磨你,你怎么牛逼呢 下面这些错是我在跑一个storm程序 ...
storm集群计算完成后,怎么把计算结果实时发给web容器?storm集群与web容器可能跨电脑、跨进程了
如图: [root@master blobs]# jps 8817 Jps 7930 nimbus 8076 core 3667 SecondaryNameNode 3480 NameNode 7626 Quor ...
各位大虾: 现有如下问题,求助各位。 storm的worker数量应该按照什么规则去创建。是按照CPU核数创建?比如storm为8核,就定义 ...
在storm运行时期,发现某个spout存在大量failed情况,从而造成其余spout处理变得很慢,最高造成了38分钟的延时。想请教问下,某 ...
我想统计在每分钟内,出现次数最多的10个ip
大神们,有个问题咨询下大家设计完拓扑后,bolt的executors和tasks数应该如何设计? 测试发现有的bolt是在20能达到最佳速度,有 ...
我想每60s 执行一次emit操作 同时清理一个map 该怎么实现呢?
7532 [Thread-16-spout-executor[3 3]] INFO o.a.s.k.ZkCoordinator - Task [1/1] Refreshing partition manager connections ...
问题导读: 1.Storm有哪几种消息保证机制?2.如何实现可靠的 Bolt?3.Trident 中,Spout 和 State 分别有哪几种状态? ...
org.apache.atlas.notification.NotificationException: java.util.concurrent.ExecutionException: org.apache.kafka.common.er ...
环境信息 s1 nimbus s2 supervisor s3 supervisor s4 supervisor storm提交两个拓扑,tp1,tp2,每 ...
求指教
kafka、storm与hdfs整合,将topology在storm运行后,运行正常。查看ui、nimbus、supervisor、worker.log文件都没报错。没有将数 ...
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 ...
defaultScheduler会在为topology分配任务之前释放掉其他topology不再需要的资源,即bad slots,哪位大神能否讲什么情况下会出现t ...
storm1.0.1安装完成以后,配置storm-yaml.xml,以下三项已修改: storm.zookeeper.servers: - "yun01-nn-02" - "yu ...
kafka_2.10 strom-0.9.6 因为下载的storm/external里面有storm-kafka的jar包所以直接用的这个。 但是在运行的时候会报错: j ...
这个问题一直困扰了我许久!我的spout 运行到某个时间,Acked 处理的tuple数就不增加了,也就没有处理tuple了,但是spout Emitte ...
我的spout数据源是来自消息队列kafka,然后发射出去给bolt处理。一般我们可能会遇到spout Failed的情况,但是我有个疑惑:为何我 ...
storm-kafka用的是0.10.0 这个版本里面找不到SpoutConfig.forceFromStart 这个配置项 需要怎么设置storm读取kafka中新消息,而 ...
启动storm的拓扑时报了这个异常: 2016-05-31T19:49:24.749+0800 b.s.d.worker [ERROR] Error on initialization of server mk- ...
本版积分规则 发表帖子
查看 »