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;