帐户注册

登录

找回密码

忘记密码了?输入你的注册邮箱,并点击重置,稍后,你将会收到一封密码重置邮件。

关于storm的topology启动时间过长(端口占用)如何解决?

storm版本是0.9.4 ,当storm集群上任务比较多的时候,启动一个topology,要过5-10分钟或者更久才能启动起来。worker log报错如下: 2016-03-21T09:58:31.217+0800 b.s.m.n.Client [ERROR] connection attempt 4 to Netty-Client-sslave6 failed: java.lang.RuntimeException: Returned channel was actually not established

查看全文

怎么实现spark中不同的分组对应不同处理函数?

现在在处理机器监控的数据,包括内存、网络、CPU等数据,是一个实时流数据,使用spark streaming作为处理平台。在实际的使用中,需要根据监控的内容分组做时间序列,然后根据不同的监控内容需要使用不同的分析函数,这时就出现了一个问题,处理内存、网络和CPU的判断标准完全不一样,请问应该如何解决?

查看全文