hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1064414 - in /incubator/hama/trunk/src: java/org/apache/hama/bsp/BSPJob.java test/org/apache/hama/bsp/TestBSPPeer.java
Date Fri, 28 Jan 2011 01:31:50 GMT
Author: edwardyoon
Date: Fri Jan 28 01:31:49 2011
New Revision: 1064414

URL: http://svn.apache.org/viewvc?rev=1064414&view=rev
Log:
Small changes: removing unnecessary method.

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPJob.java
    incubator/hama/trunk/src/test/org/apache/hama/bsp/TestBSPPeer.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPJob.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPJob.java?rev=1064414&r1=1064413&r2=1064414&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPJob.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPJob.java Fri Jan 28 01:31:49 2011
@@ -52,20 +52,6 @@ public class BSPJob extends BSPJobContex
     super(new Path(jobFile), jobID);
   }
 
-  /**
-   * Only for unit test
-   * 
-   * TODO will be deleted when miniBSPCluster implemented
-   * 
-   * @param conf
-   * @param tasks
-   * @throws IOException
-   */
-  public BSPJob(HamaConfiguration conf, int tasks) throws IOException {
-    super(conf, null);
-    setNumBspTask(tasks);
-  }
-
   public BSPJob(HamaConfiguration conf, Class<?> exampleClass) throws IOException {
     this(conf);
     setJarByClass(exampleClass);

Modified: incubator/hama/trunk/src/test/org/apache/hama/bsp/TestBSPPeer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/test/org/apache/hama/bsp/TestBSPPeer.java?rev=1064414&r1=1064413&r2=1064414&view=diff
==============================================================================
--- incubator/hama/trunk/src/test/org/apache/hama/bsp/TestBSPPeer.java (original)
+++ incubator/hama/trunk/src/test/org/apache/hama/bsp/TestBSPPeer.java Fri Jan 28 01:31:49
2011
@@ -59,8 +59,6 @@ public class TestBSPPeer extends HamaClu
   }
 
   public void setUp() throws Exception {
-    super.setUp();
-
     ZooKeeper zk = new ZooKeeper("localhost:21810", 3000, this);
     Stat s = null;
     if (zk != null) {
@@ -99,7 +97,8 @@ public class TestBSPPeer extends HamaClu
       TaskStatus currentTaskStatus = new TaskStatus(new BSPJobID(), 
           new TaskAttemptID(), 0, null, null, null, null);
       peer.setCurrentTaskStatus(currentTaskStatus);
-      BSPJob jobConf = new BSPJob(conf, NUM_PEER);
+      BSPJob jobConf = new BSPJob(conf);
+      jobConf.setNumBspTask(NUM_PEER);
       peer.setJobConf((BSPJob) jobConf);
     }
 



Mime
View raw message