用户组:游客
问题导读 1.Hadoop3.3支持JDK哪个版本? 2.SCM是什么? 3.YARN应用程序做了哪些改进? 4.整合腾讯云实现了什么文件系统? ...
storm这个异常怎么解决,每天出现1~2次
这个拒绝连接的错误是怎么回事?如何解决?谢谢!!
链接:http://pan.baidu.com/s/1bntx9mB 密码:**** 本内容被作者隐藏 ****
这个是什么错误,在安装集群的时候?????在线等
KafkaSpout 消费kafka的时候有设置kafka消费者组这个属性吗?有的话是哪一个属性字段?谢谢
来自群友整理之: storm,所有的bolt都没抛异常,但spout就有failed的。。。求解。。。 原因: 超时 默认的超时时间 ...
机器学习里面的提升(Boosting)问题在在线学习(online learning)上的应用。比如数据一个一个地到来,并通过多个弱学习器进行 ...
TridentTopology tridentTopology = new TridentTopology(); Stream stream = tridentTopology.newStream("event", kafkaSpout) ...
Storn可以设置动态的时间滑动窗口吗?可以的话怎样写?
目前,遇到一个棘手的问题,storm集群运行过程中,出现数据不处理情况。 架构是kafka-storm-db 当db服务器宕机后,storm由于部 ...
在storm运行时期,发现某个spout存在大量failed情况,从而造成其余spout处理变得很慢,最高造成了38分钟的延时。想请教问下,某 ...
问题导读: 1.Storm有哪几种消息保证机制?2.如何实现可靠的 Bolt?3.Trident 中,Spout 和 State 分别有哪几种状态? ...
storm集群计算完成后,怎么把计算结果实时发给web容器?storm集群与web容器可能跨电脑、跨进程了
[root@hadoop1 storm-yarn-master]# mvn package Scanning for projects... ...
1个worker进程执行的是1个topology的子集(注:不会出现1个worker为多个topology服务)。1个worker进程会启动1个或多个executor ...
这些一大堆报错,你我都不要愿意看,更不想它出现,可没有这些东西折磨你,你怎么牛逼呢 下面这些错是我在跑一个storm程序 ...
我目前就剩一台storm服务器了。 然后我的程序是一个Spout,2个Bolt 大概的逻辑是Spout ,从kafka里取数据出来。 Bolt1在消 ...
如图: [root@master blobs]# jps 8817 Jps 7930 nimbus 8076 core 3667 SecondaryNameNode 3480 NameNode 7626 Quor ...
各位大虾: 现有如下问题,求助各位。 storm的worker数量应该按照什么规则去创建。是按照CPU核数创建?比如storm为8核,就定义 ...
为什么启动superviosr时,启动成功之后,过2、3秒钟就提示Kill No Such process,然后superviosr就死掉了??
storm-kafka用的是0.10.0 这个版本里面找不到SpoutConfig.forceFromStart 这个配置项 需要怎么设置storm读取kafka中新消息,而 ...
我部署了一套kafka,启动正常,接收消息时也能正常接收,但总会抛出异常,异常情况如下,我查了下,好像是kafka2.8.0版本的一个b ...
链接:http://pan.baidu.com/s/1dD54NVb 密码:**** 本内容被作者隐藏 ****
我想统计在每分钟内,出现次数最多的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 ...
TopologyBuilder topology = new TopologyBuilder(); topology.setSpout("KafkaReader", new KafkaSpout(spoutConfig) , 6); ...
我在使用storm 0.9.2-incubating, local mode.
org.apache.atlas.notification.NotificationException: java.util.concurrent.ExecutionException: org.apache.kafka.common.er ...
本版积分规则 发表帖子
查看 »