对Hama进行改进,引用了一个类A(A继承了线程类),当该类实现如下时,:
GraphJobRunner中
@Override
public final void setup(
BSPPeer<Writable, Writable, Writable, Writable, GraphJobMessage> peer)
throws IOException, SyncException, InterruptedException {
setupFields(peer);
loadVertices(peer);
countGlobalVertexCount(peer);
doInitialSuperstep(peer);
}
private void setupFields(
.....
A a = new A;
a.start() ;
vertices.init(this, conf, peer.getTaskId());
}
运行时就IPC就开始不稳定了,mu02就会持续掉线再连上,子节点的日志则无此问题。。。。 不知道是咋回事。
日志显示如下:
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37703. Number of active connections: 20
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37710. Number of active connections: 19
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37718. Number of active connections: 18
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37724. Number of active connections: 17
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to c02b01/192.168.0.21:61001 from liuqiang2: closed
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to c02b01/192.168.0.21:61001 from liuqiang2: stopped, remaining connections 15
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.30:41874. Number of active connections: 16
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.21:42530. Number of active connections: 15
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37733. Number of active connections: 14
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to c02b01/192.168.0.21:61002 from liuqiang2: closed
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to c02b01/192.168.0.21:61002 from liuqiang2: stopped, remaining connections 14
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to mu02/192.168.0.100:61006 from liuqiang2: closed
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to mu02/192.168.0.100:61006 from liuqiang2: stopped, remaining connections 13
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to mu02/192.168.0.100:61005 from liuqiang2: closed
15/03/05 21:52:49 DEBUG ipc.Client: IPC Client (47) connection to mu02/192.168.0.100:61005 from liuqiang2: stopped, remaining connections 12
15/03/05 21:52:49 DEBUG ipc.Server: IPC Server listener on 61005: disconnecting client 192.168.0.100:37738. Number of active connections: 13
非常奇怪!
后来尝试将
a.start() ; 放到loadVertices中
loadVertices{
a.start() ;
...
}
就好了。。。。 这尼玛能差几行代码啊?????? 哪位知道是咋回事啊。。。。
分享到:
相关推荐
50 听起来很恐怖的数据库幻读,到底是个什么奇葩问题?l.pdf
所见过的13种最为奇葩的编程语言,无聊之余的谈资. 不喜勿喷
html5微信小游戏源码 奇葩连连看游戏源码(仅用于参考)html5微信小游戏源码 奇葩连连看游戏源码(仅用于参考)html5微信小游戏源码 奇葩连连看游戏源码(仅用于参考)html5微信小游戏源码 奇葩连连看游戏源码(仅...
Feign配置扫描包出现奇葩问题.docx
奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗拿SHELL奇葩过最新安全狗...
奇葩版Flappy Bird游戏源代码,
奇葩连连看HTML5游戏源码,运行需要服务器环境,已经反复测试,放心使用。
奇葩工具箱2014.10.19最新版本 奇葩工具箱Beta5.0.8更新内容: 1.修复*启动程序后右上角显示不明标签问题; 2.调整*对奇葩闹钟功能做了一点调整; 3.取消*QQ个性网名,签名,头像,分组大全等QQ相册封面拼图; 4....
微信小游戏源码 奇葩连连看游戏源码(仅用于学习参考)微信小游戏源码 奇葩连连看游戏源码(仅用于学习参考)微信小游戏源码 奇葩连连看游戏源码(仅用于学习参考)微信小游戏源码 奇葩连连看游戏源码(仅用于学习...
下面我们精选了10个奇葩问题,如果你能顺利回答上来的话,也许就能进入梦寐以求的科技企业啦。
使用afnPOST请求不正规json数据,不能解析,最终通过简单思路实现了,其中涉及到非json字符窜,转json字符窜再解析json字符窜
辩论赛节目:观《奇葩说》之朋友圈该不该屏蔽父母语言记录.docx
奇葩115.docx
《江南戏曲奇葩——越剧》教学设计2.pdf
行业-50 听起来很恐怖的数据库幻读,到底是个什么奇葩问题?l.rar
12306奇葩验证码原理,讲述了生成的原理和验证的原理,12306奇葩验证码原理
安卓奇葩音乐播放器源码是个奇葩其实一点也不冤枉这个项目,整个播放器只有一个循环播放的动画画面,打开软件会自动扫描SD卡上的音乐并且把少于一分钟的音频过滤掉然后随机播放一个音乐。项目权当娱乐了,可以把动画...
奇葩工具箱以QQ、贴吧、电脑等相关为主题大即可功能工具箱。
钢琴音乐的奇葩.ppt