用户组:游客
SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "mykafka", "mytop1"); TopologyBuilder builder = new TopologyB ...
请问哪位大神指导如何解决该问题: 我定义了个topology,spout是负责读取文件后,转为消息流emit出去的。但现在有个烦恼的 ...
如题,Storm并行度与kafka分区数是否有关系呢? BrokerHosts brokerHosts = new ZkHosts(zkConnString); SpoutConfig spoutCon ...
背景:我在远程的Linux服务器上安装了kafka,Linux上测试可以发送和接收消息,本地idea上本地模式运行storm,获取远程Linux上kaf ...
想请教一下,storm如何从日志中统计过去十分钟内同一ip的个数?
本人storm初学者,用阿里的jstorm。 zookeeper能正常启动运行,并能用zkCli.sh联上。 但jstorm nimbus报了错, 如下: [mw_s ...
storm运行时bolt报异常,也不是经常出现这个异常,我查了下网上的解释:这个信息表示你在将一个可变的对象作为 tuple 发送出去。 ...
[root@linux5 bin]# storm nimbus Traceback (most recent call last): File "/export/servers/storm/bin/storm", line 51 ...
在storm端接受kafka数据时,采用的高级的consumer api,就是通过groupid来接收kafka中的数据 如果我spout的任务开多了会不会影 ...
写了一个Topology,发布上去后,但在UI界面上看不到这个Topology的执行信息,但实际上已经执行了,数据都有插入表中,我看了后台 ...
我在eclipse写了一个topology,其中有有个bolt:import org.apache.hadoop.conf.Configuration; 应用的是hadoop-commond-2.2.0.j ...
如题,在安装storm集群的时候,一般都需要安装zeromq和Jzmq,但是kafka和zeromq的作用看起来差不多,都是用来做mq传输用的,那么 ...
比如说我的数据是这样的name age sex a 23 男 b 22 女 c 22 ...
1个worker进程执行的是1个topology的子集(注:不会出现1个worker为多个topology服务)。1个worker进程会启动1个或多个executor ...
在生产环境如何建立一个合适的storm集群,比如说,我需要给nimbus、supervisor、worker分配多少内存,启用多少个supervisor?我 ...
我在eclipse中运行了本地模式,却报错,错误如下: LocalCluster cluster = new LocalCluster(); cluster.sub ...
本地也映射了 hostname ip 也能ping通地址,但就是访问不到日志链接 查看 启动logviewer 的日志发现: 2015-06-30 17 ...
本帖最后由 tntzbzc 于 2015-8-19 19:39 编辑 2015-08-19 15:39:30 b.s.d.nimbus [ERROR] Error on initialization of server ...
求指教
storm启动不了了 supervisor 日志报错如下
kafka、storm与hdfs整合,将topology在storm运行后,运行正常。查看ui、nimbus、supervisor、worker.log文件都没报错。没有将数 ...
由于怕系统太繁忙而导致消息处理不及时,所以storm设置了一个超时时间比较长 conf.setMessageTimeoutSecs(300); 当设置这个以 ...
求资料分享,买了几本书十几分钟就看完了啥有用的都没有
请问哪位大神实际用过cgroup进行storm的资源隔离啊,求教!!!
A: 这个数字是什么意思? B: 开两个线程 A: 两个bolt的执行顺序是怎么确定的 B: 看shuffleGro ...
发现日志文件里不停的在打下面的日志,一秒有几十条,这是什么情况啊?哪位帮忙看看 2016-01-12 13:07:44.265 o.a.h.h.z.Reco ...
我的问题已经在标题中描述出来了,下面我详细的描述下我的问题。看了storm,知道他用nimbus\zk\supervisor通过主从结构来搭建集 ...
RT,按照网上的配置配置好后,执行 storm nimbus,报图中的错误,不知道如何解决,恳请大家帮忙看看是哪里的原因,万分感谢~ ...
在运用kafka+storm进行日志分析时,发生kafka消息堆积,在storm的worker日志里面看到如下异常日志,完全跟自己的业务代码无关, ...
本版积分规则 发表帖子
查看 »