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/12/13 02:26:13 UTC

svn commit: r1421058 - in /hama/trunk: contrib/avro-rpc/ contrib/avro-rpc/src/ contrib/avro-rpc/src/main/ contrib/avro-rpc/src/main/java/ contrib/avro-rpc/src/main/java/org/ contrib/avro-rpc/src/main/java/org/apache/ contrib/avro-rpc/src/main/java/org/...

Author: edwardyoon
Date: Thu Dec 13 01:26:11 2012
New Revision: 1421058

URL: http://svn.apache.org/viewvc?rev=1421058&view=rev
Log:
Move Avro RPC to contrib project

Added:
    hama/trunk/contrib/avro-rpc/
    hama/trunk/contrib/avro-rpc/src/
    hama/trunk/contrib/avro-rpc/src/main/
    hama/trunk/contrib/avro-rpc/src/main/java/
    hama/trunk/contrib/avro-rpc/src/main/java/org/
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/AvroBSPMessageBundle.java
      - copied unchanged from r1421053, hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroBSPMessageBundle.java
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/AvroMessageManagerImpl.java
      - copied unchanged from r1421053, hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroMessageManagerImpl.java
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/Sender.java
      - copied unchanged from r1421053, hama/trunk/core/src/main/java/org/apache/hama/bsp/message/Sender.java
    hama/trunk/contrib/avro-rpc/src/main/java/org/apache/hama/avro/TestAvroMessageManager.java
      - copied unchanged from r1421053, hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Removed:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroBSPMessageBundle.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AvroMessageManagerImpl.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/Sender.java
    hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Modified:
    hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java?rev=1421058&r1=1421057&r2=1421058&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestDiskQueue.java Thu Dec 13 01:26:11 2012
@@ -29,11 +29,11 @@ import org.apache.hama.bsp.message.queue
 import org.junit.Test;
 
 public class TestDiskQueue extends TestCase {
+  public static final String TMP_OUTPUT_PATH = "/tmp/messageQueue";
 
   static Configuration conf = new Configuration();
   static {
-    conf.set(DiskQueue.DISK_QUEUE_PATH_KEY,
-        TestAvroMessageManager.TMP_OUTPUT_PATH);
+    conf.set(DiskQueue.DISK_QUEUE_PATH_KEY, TMP_OUTPUT_PATH);
   }
 
   @Test