svn commit: r1242637 [2/2] - in /incubator/hama/trunk: ./ core/src/main/java/org/apache/hama/bsp/ core/src/main/java/org/apache/hama/bsp/message/ core/src/test/java/org/apache/hama/bsp/ core/src/test/java/org/apache/hama/bsp/message/ core/src/test/java...

[edwardyoon]

Modified: 
incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
URL: 
http://svn.apache.org/viewvc/incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java?rev=1242637&r1=1242636&r2=1242637&view=diff
==============================================================================
--- 
incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
 (original)
+++ 
incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
 Fri Feb 10 02:06:10 2012
@@ -29,7 +29,7 @@ import org.apache.hama.bsp.sync.SyncExce
 public class YarnSerializePrinting {
 
   public static class HelloBSP extends
-      BSP<NullWritable, NullWritable, NullWritable, NullWritable> {
+      BSP<NullWritable, NullWritable, NullWritable, NullWritable, 
NullWritable> {
     public static final Log LOG = LogFactory.getLog(HelloBSP.class);
     private Configuration conf;
     private final static int PRINT_INTERVAL = 1000;
@@ -37,7 +37,7 @@ public class YarnSerializePrinting {
 
     @Override
     public void bsp(
-        BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable> 
bspPeer)
+        BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable, 
NullWritable> bspPeer)
         throws IOException, SyncException, InterruptedException {
       num = conf.getInt("bsp.peers.num", 0);
       LOG.info(bspPeer.getAllPeerNames());