hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bs...@apache.org
Subject svn commit: r1628356 - in /hama/trunk: ./ core/src/main/java/org/apache/hama/bsp/message/ core/src/main/java/org/apache/hama/ipc/ core/src/test/java/org/apache/hama/bsp/message/ core/src/test/java/org/apache/hama/ipc/
Date Tue, 30 Sep 2014 02:42:54 GMT
Author: bsmin
Date: Tue Sep 30 02:42:54 2014
New Revision: 1628356

URL: http://svn.apache.org/r1628356
Log:
HAMA-913: correct the configuration of the subversion client(re-commit)

Modified:
    hama/trunk/CHANGES.txt
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaAsyncMessageManagerImpl.java
    hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncClient.java
    hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncRPC.java
    hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncServer.java
    hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaAsyncMessageManager.java
    hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncIPC.java
    hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncRPC.java

Modified: hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hama/trunk/CHANGES.txt?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/CHANGES.txt (original)
+++ hama/trunk/CHANGES.txt Tue Sep 30 02:42:54 2014
@@ -19,7 +19,6 @@ Release 0.7.0 (unreleased changes)
   IMPROVEMENTS
    HAMA-913: Add RPC implementation using netty(bsmin)  
    HAMA-914: Boolean flag (isCompressed) is required only when runtime compression is enabled
(edwardyoon)
-   HAMA-914: Boolean flag (isCompressed) is required only when runtime compression is enabled
(edwardyoon)
    HAMA-910: Web UI Improvement (Victor Lee via edwardyoon)
    HAMA-909: Improve Mesos Scheduler's Fault Tolerance (Jeff Fenchel via edwardyoon)
    HAMA-823: Remove javadoc warnings (Victor Lee via edwardyoon)  

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaAsyncMessageManagerImpl.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaAsyncMessageManagerImpl.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaAsyncMessageManagerImpl.java
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HamaAsyncMessageManagerImpl.java
Tue Sep 30 02:42:54 2014
@@ -37,7 +37,7 @@ import org.apache.hama.ipc.AsyncServer;
 import org.apache.hama.util.LRUCache;
 
 /**
- * Implementation of the {@link HamaMessageManager}.
+ * Implementation of the {@link HamaMessageManager}
  * 
  */
 public final class HamaAsyncMessageManagerImpl<M extends Writable> extends

Modified: hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncClient.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncClient.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncClient.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncClient.java Tue Sep 30 02:42:54
2014
@@ -981,7 +981,7 @@ public class AsyncClient {
     /*
      * we could avoid this allocation for each RPC by having a connectionsId
      * object and with set() method. We need to manage the refs for keys in
-     * HashMap properly. For now its ok.
+     * HashMap properly. For now its ok
      */
     do {
       connection = connections.get(remoteId);

Modified: hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncRPC.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncRPC.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncRPC.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncRPC.java Tue Sep 30 02:42:54 2014
@@ -180,7 +180,7 @@ public class AsyncRPC {
       // connection pooling and leak sockets, or (b) use the same timeout for
       // all
       // configurations. Since the IPC is usually intended globally, not
-      // per-job, we choose (a).
+      // per-job, we choose (a)
       AsyncClient client = clients.get(factory);
       if (client == null) {
         client = new AsyncClient(ObjectWritable.class, conf, factory);

Modified: hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncServer.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncServer.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncServer.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/ipc/AsyncServer.java Tue Sep 30 02:42:54
2014
@@ -77,7 +77,7 @@ public abstract class AsyncServer {
   // 4 : Introduced SASL security layer
   static final byte CURRENT_VERSION = 4;
   static final int HEADER_LENGTH = 10;
-  // follows version is read.
+  // follows version is read
   private Configuration conf;
   private final boolean tcpNoDelay; // if T then disable Nagle's Algorithm
   private int backlogLength;;

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaAsyncMessageManager.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaAsyncMessageManager.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaAsyncMessageManager.java
(original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHamaAsyncMessageManager.java
Tue Sep 30 02:42:54 2014
@@ -42,7 +42,7 @@ public class TestHamaAsyncMessageManager
 
   public static final String TMP_OUTPUT_PATH = "/tmp/messageQueue";
   // increment is here to solve race conditions in parallel execution to choose
-  // other ports.
+  // other ports
   public static volatile int increment = 1;
 
   public void testMemoryMessaging() throws Exception {

Modified: hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncIPC.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncIPC.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncIPC.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncIPC.java Tue Sep 30 02:42:54
2014
@@ -98,7 +98,7 @@ public class TestAsyncIPC extends TestCa
           }
 
         } catch (Exception e) {
-          LOG.fatal("Caught: " + StringUtils.stringifyException(e));
+          LOG.fatal("Caught : " + StringUtils.stringifyException(e));
           failed = true;
         }
       }

Modified: hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncRPC.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncRPC.java?rev=1628356&r1=1628355&r2=1628356&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncRPC.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/ipc/TestAsyncRPC.java Tue Sep 30 02:42:54
2014
@@ -34,7 +34,7 @@ public class TestAsyncRPC extends TestCa
   private static final String ADDRESS = "0.0.0.0";
 
   public static final Log LOG = LogFactory
-      .getLog("org.apache.hama.ipc.TestRPCWithNetty");
+      .getLog("org.apache.hama.ipc.TestAsyncRPC");
 
   private static Configuration conf = new Configuration();
 



Mime
View raw message