You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2011/10/18 08:26:40 UTC
svn commit: r1185495 -
/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
Author: edwardyoon
Date: Tue Oct 18 06:26:39 2011
New Revision: 1185495
URL: http://svn.apache.org/viewvc?rev=1185495&view=rev
Log:
Trivial fix getBSPConnection()
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java?rev=1185495&r1=1185494&r2=1185495&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java Tue Oct 18 06:26:39 2011
@@ -596,15 +596,9 @@ public class BSPPeerImpl implements Watc
synchronized (this.peers) {
peer = peers.get(addr);
- int retries = 0;
- while (peer != null) {
- peer = (BSPPeer) RPC.getProxy(BSPPeer.class,
+ if(peer == null) {
+ peer = (BSPPeer) RPC.getProxy(BSPPeer.class,
BSPPeer.versionID, addr, this.conf);
-
- retries++;
- if (retries > 10) {
- umbilical.fatalError(taskid, addr + " doesn't repond.");
- }
}
this.peers.put(addr, peer);