Index: src/java/org/apache/hama/bsp/BSPPeer.java =================================================================== --- src/java/org/apache/hama/bsp/BSPPeer.java (revision 950837) +++ src/java/org/apache/hama/bsp/BSPPeer.java (working copy) @@ -79,7 +79,7 @@ public void reinitialize() { try { - System.out.println(bindAddress + ":" + bindPort); + LOG.debug("reinitialize(): " + bindAddress + ":" + bindPort); server = RPC.getServer(this, bindAddress, bindPort, conf); server.start(); } catch (IOException e) { @@ -237,4 +237,9 @@ return peer; } + + @Override + public String getServerName() { + return this.serverName; + } } Index: src/java/org/apache/hama/bsp/BSPPeerInterface.java =================================================================== --- src/java/org/apache/hama/bsp/BSPPeerInterface.java (revision 950837) +++ src/java/org/apache/hama/bsp/BSPPeerInterface.java (working copy) @@ -23,4 +23,6 @@ public void put(BSPMessage msg) throws IOException; public boolean isRunning(); + + public String getServerName(); } Index: src/test/org/apache/hama/bsp/UserInterface.java =================================================================== --- src/test/org/apache/hama/bsp/UserInterface.java (revision 950840) +++ src/test/org/apache/hama/bsp/UserInterface.java (working copy) @@ -73,7 +73,7 @@ } if (pi != 0.0) - System.out.println(pi); + System.out.println(peer.getServerName() + ": " + pi); } }