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 2012/03/09 02:57:36 UTC

svn commit: r1298687 - in /incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp: TestBSPTaskFaults.java message/TestAvroMessageManager.java

Author: edwardyoon
Date: Fri Mar  9 01:57:36 2012
New Revision: 1298687

URL: http://svn.apache.org/viewvc?rev=1298687&view=rev
Log:
Quick fix build fails.

Modified:
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java?rev=1298687&r1=1298686&r2=1298687&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java Fri Mar  9 01:57:36 2012
@@ -54,6 +54,7 @@ import org.apache.hama.bsp.sync.SyncClie
 import org.apache.hama.bsp.sync.SyncException;
 import org.apache.hama.bsp.sync.SyncServiceFactory;
 import org.apache.hama.ipc.BSPPeerProtocol;
+import org.apache.hama.util.BSPNetUtils;
 
 public class TestBSPTaskFaults extends TestCase {
 
@@ -416,7 +417,7 @@ public class TestBSPTaskFaults extends T
         LocalBSPRunner.LocalSyncClient.class, SyncClient.class);
 
     int testNumber = incrementTestNumber();
-    InetSocketAddress inetAddress = new InetSocketAddress(54321 + testNumber);
+    InetSocketAddress inetAddress = new InetSocketAddress(BSPNetUtils.getFreePort(34321) + testNumber);
     groom = new MinimalGroomServer(conf);
     workerServer = RPC.getServer(groom, inetAddress.getHostName(),
         inetAddress.getPort(), conf);

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java?rev=1298687&r1=1298686&r2=1298687&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java Fri Mar  9 01:57:36 2012
@@ -39,9 +39,9 @@ import org.apache.hama.util.BSPNetUtils;
 
 public class TestAvroMessageManager extends TestCase {
 
-  private static final int DOUBLE_MSG_COUNT = 400000;
-  private static final int BOOL_MSG_COUNT = 10000;
-  private static final int INT_MSG_COUNT = 500000;
+  private static final int DOUBLE_MSG_COUNT = 4000;
+  private static final int BOOL_MSG_COUNT = 1000;
+  private static final int INT_MSG_COUNT = 5000;
 
   private static final int SUM = DOUBLE_MSG_COUNT + BOOL_MSG_COUNT
       + INT_MSG_COUNT;