用户组:游客
问题导读 1.Hadoop3.3支持JDK哪个版本? 2.SCM是什么? 3.YARN应用程序做了哪些改进? 4.整合腾讯云实现了什么文件系统? ...
链接:http://pan.baidu.com/s/1bntx9mB 密码:**** 本内容被作者隐藏 ****
链接:http://pan.baidu.com/s/1dD54NVb 密码:**** 本内容被作者隐藏 ****
我现在有两个Topology,想消费同一个 topic,请问我需要设置什么参数吗?
我部署了一套kafka,启动正常,接收消息时也能正常接收,但总会抛出异常,异常情况如下,我查了下,好像是kafka2.8.0版本的一个b ...
需求:有一个项目类似QQ发送消息的,可以单发,群发。客户希望能实时看到消息发送量的折线图(按小时为单位)。目前数据存入的是 ...
在执行storm过程中出现如下的异常,虽然不影响结果,但是还是求教为什么会出现这样的异常,该怎么解决呢? 9782 [Thread-6-Send ...
来自群友整理之: storm,所有的bolt都没抛异常,但spout就有failed的。。。求解。。。 原因: 超时 默认的超时时间 ...
想写个简单的Storm处理滑动窗口求和的程序,但是无奈遇到问题,还请各位大神不吝赐教。 现有数据存放在某个文件中,内容如下: ...
我目前就剩一台storm服务器了。 然后我的程序是一个Spout,2个Bolt 大概的逻辑是Spout ,从kafka里取数据出来。 Bolt1在消 ...
[hadoop@hadoop26 .storm]$ storm jar ~/storm/storm-yarn-master/lib/storm-starter-0.0.1-SNAPSHOT.jar storm.starter.WordCou ...
在storm运行时期,发现某个spout存在大量failed情况,从而造成其余spout处理变得很慢,最高造成了38分钟的延时。想请教问下,某 ...
有storm相关的视频可以下载的吗? 各位大神知道哪里有storm视频资源可以下载吗?
TopologyBuilder topology = new TopologyBuilder(); topology.setSpout("KafkaReader", new KafkaSpout(spoutConfig) , 6); ...
请教些问题: 本人现在在着手写实时计算方面的论文,现在思路还是有点乱, (1) 关于实时计算有哪些算法可以去研究下; ...
我想统计在每分钟内,出现次数最多的10个ip
storm集群计算完成后,怎么把计算结果实时发给web容器?storm集群与web容器可能跨电脑、跨进程了
我发布到storm上的topology运行良好,但奇怪的时候,我第二天过来,总是发现整个stormshutdown 我查看了nimbus.log,superviso ...
想测试下storm的性能,应该使用什么样的测试例子比较好呢,应该从哪几方面下手,
我首先手动发送一条 消息 :hello word 到kafka 然后通过storm程序接受这条消息并打印出来,但是消息是打印出来了,就是总是报 ...
github上有个 storm-hive-streaming-example-master的例子,我就试着搭了环境测试下,但是就在要往hive中写数据的那个bolt总是链 ...
想问一下大家 本地模式是不是本地程序直接可以跑起来? 不需要大环境? 也不需要将storm的jar包上传到服务器?
最近在做项目,有些业务复杂点的 用简单的 topology 感觉实现起来有点牵强。所以就研究研究trident,然后看到了流合并 merge和jo ...
工程结构如下,我没有用maven来构建工程 高手们问个问题,刚接触storm,我在windows环境下用myeclipse构建了一个storm的dem ...
这个问题一直困扰了我许久!我的spout 运行到某个时间,Acked 处理的tuple数就不增加了,也就没有处理tuple了,但是spout Emitte ...
在storm中,可以支持一些比较复杂的算么?比如处理图片的算法
Storm中的Spout设置并行度为4 读取同一个文件,会不会读取这个文件的四份啊
有些时候看到发送消息的时候 这句或者 使用上传递方法bolt或者spout会接收两个参数,还是接收到后面的参数?
运行storm jar的时候会报java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy这个错误 我的pom里面有这个jar包 ...
storm-kafka用的是0.10.0 这个版本里面找不到SpoutConfig.forceFromStart 这个配置项 需要怎么设置storm读取kafka中新消息,而 ...
torm打jar,我把自定义配置文件打在jar包的外面,提交到集群上之后,这个配置文件应该放在集群的什么位置啊?
本版积分规则 发表帖子
查看 »