You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by tj...@apache.org on 2011/10/12 17:55:37 UTC

svn commit: r1182452 - in /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp: BSP.java BSPTask.java

Author: tjungblut
Date: Wed Oct 12 15:55:37 2011
New Revision: 1182452

URL: http://svn.apache.org/viewvc?rev=1182452&view=rev
Log:
Adding checked exceptions to the setup method and moved it into the try catch statement

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSP.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPTask.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSP.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSP.java?rev=1182452&r1=1182451&r2=1182452&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSP.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSP.java Wed Oct 12 15:55:37 2011
@@ -35,7 +35,8 @@ public abstract class BSP implements BSP
    * 
    * @param peer Your BSPPeer instance.
    */
-  public void setup(BSPPeer peer) {
+  public void setup(BSPPeer peer) throws IOException, KeeperException,
+      InterruptedException {
 
   }
 

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPTask.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPTask.java?rev=1182452&r1=1182451&r2=1182452&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPTask.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPTask.java Wed Oct 12 15:55:37 2011
@@ -57,9 +57,8 @@ public class BSPTask extends Task {
     BSP bsp = (BSP) ReflectionUtils.newInstance(
         job.getConf().getClass("bsp.work.class", BSP.class), job.getConf());
 
-    bsp.setup(bspPeer);
-
     try {
+      bsp.setup(bspPeer);
       bsp.bsp(bspPeer);
     } catch (IOException e) {
       LOG.error("Exception during BSP execution!", e);