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 2014/08/12 03:52:05 UTC

svn commit: r1617395 - /hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java

Author: edwardyoon
Date: Tue Aug 12 01:52:04 2014
New Revision: 1617395

URL: http://svn.apache.org/r1617395
Log:
test

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

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java?rev=1617395&r1=1617394&r2=1617395&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/TestBSPTaskFaults.java Tue Aug 12 01:52:04 2014
@@ -70,7 +70,7 @@ public class TestBSPTaskFaults extends T
   private volatile BSPPeerProtocol umbilical;
   private Server workerServer;
   private TaskAttemptID taskid = new TaskAttemptID(new TaskID(new BSPJobID(
-      "job_201110302255", 1), 1), 1);
+      "job_201410302255", 1), 1), 1);
 
   public volatile HamaConfiguration conf;
 
@@ -423,7 +423,7 @@ public class TestBSPTaskFaults extends T
     conf.setClass(SyncServiceFactory.SYNC_PEER_CLASS,
         LocalBSPRunner.LocalSyncClient.class, SyncClient.class);
 
-    int port = BSPNetUtils.getFreePort(34321 + incrementTestNumber());
+    int port = BSPNetUtils.getFreePort(4321 + incrementTestNumber());
     try {
       InetSocketAddress inetAddress = new InetSocketAddress(port);
       groom = new MinimalGroomServer(conf);