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;