用户组:游客
链接:http://pan.baidu.com/s/1bntx9mB 密码:**** 本内容被作者隐藏 ****
链接:http://pan.baidu.com/s/1dD54NVb 密码:**** 本内容被作者隐藏 ****
在执行storm过程中出现如下的异常,虽然不影响结果,但是还是求教为什么会出现这样的异常,该怎么解决呢? 9782 [Thread-6-Send ...
想写个简单的Storm处理滑动窗口求和的程序,但是无奈遇到问题,还请各位大神不吝赐教。 现有数据存放在某个文件中,内容如下: ...
我现在有两个Topology,想消费同一个 topic,请问我需要设置什么参数吗?
需求:有一个项目类似QQ发送消息的,可以单发,群发。客户希望能实时看到消息发送量的折线图(按小时为单位)。目前数据存入的是 ...
我在使用storm 0.9.2-incubating, local mode.
有些时候看到发送消息的时候 这句或者 使用上传递方法bolt或者spout会接收两个参数,还是接收到后面的参数?
我发布到storm上的topology运行良好,但奇怪的时候,我第二天过来,总是发现整个stormshutdown 我查看了nimbus.log,superviso ...
我目前就剩一台storm服务器了。 然后我的程序是一个Spout,2个Bolt 大概的逻辑是Spout ,从kafka里取数据出来。 Bolt1在消 ...
github上有个 storm-hive-streaming-example-master的例子,我就试着搭了环境测试下,但是就在要往hive中写数据的那个bolt总是链 ...
[hadoop@hadoop26 .storm]$ storm jar ~/storm/storm-yarn-master/lib/storm-starter-0.0.1-SNAPSHOT.jar storm.starter.WordCou ...
我首先手动发送一条 消息 :hello word 到kafka 然后通过storm程序接受这条消息并打印出来,但是消息是打印出来了,就是总是报 ...
TopologyBuilder topology = new TopologyBuilder(); topology.setSpout("KafkaReader", new KafkaSpout(spoutConfig) , 6); ...
我根据这个例子来整合kafka flume storm但是会报这个错误球大神帮我解决下
我在用本地模式调试的时候在bolt中能读取到数据 而使用StormSubmitter.submitTopology的时候 storm jar运行我的打包程序 执行 ...
storm集群计算完成后,怎么把计算结果实时发给web容器?storm集群与web容器可能跨电脑、跨进程了
想问一下大家 本地模式是不是本地程序直接可以跑起来? 不需要大环境? 也不需要将storm的jar包上传到服务器?
想测试下storm的性能,应该使用什么样的测试例子比较好呢,应该从哪几方面下手,
用Storm搭设了个平台,通过KafkaSpout从kafka读取消息,但现在遇到如下问题: 1. 如果kafka消息层的消息产生速度保持在每分钟 2 ...
ip hostname 也在本地映射了 也能 ping通 IP地址 查看进程日志发现
我的Strom是集群环境一共3台机器,一个主节点2个子节点。 然后我做了一个最简单的strom例子。 SimpleSpout,获取数据,数据就 ...
RT,执行上传命令的时候,报错,希望帮忙看看是哪的问题,谢谢啦!!
我部署了一套kafka,启动正常,接收消息时也能正常接收,但总会抛出异常,异常情况如下,我查了下,好像是kafka2.8.0版本的一个b ...
[root@hadoop1 storm-yarn-master]# mvn package Scanning for projects... ...
看了一些资料,发现storm中的tuple经常被提起, 那么这个tuple指的是spout最初产生的tuple,还是任何一个bolt产生的都叫tuple ...
六台flume服务器,三台kafka服务器,大概流程是这样:flume采集数据到kafka,然后storm去kafka数据分析,为了做交易耗时统计,采 ...
有storm相关的视频可以下载的吗? 各位大神知道哪里有storm视频资源可以下载吗?
这个问题一直困扰了我许久!我的spout 运行到某个时间,Acked 处理的tuple数就不增加了,也就没有处理tuple了,但是spout Emitte ...
工程结构如下,我没有用maven来构建工程 高手们问个问题,刚接触storm,我在windows环境下用myeclipse构建了一个storm的dem ...
本版积分规则 发表帖子
查看 »