hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1390805 - /hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Date Thu, 27 Sep 2012 01:57:18 GMT
Author: edwardyoon
Date: Thu Sep 27 01:57:18 2012
New Revision: 1390805

URL: http://svn.apache.org/viewvc?rev=1390805&view=rev
Log:
Fix build failure.

Modified:
    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/TestAvroMessageManager.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java?rev=1390805&r1=1390804&r2=1390805&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
(original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java
Thu Sep 27 01:57:18 2012
@@ -46,12 +46,14 @@ public class TestAvroMessageManager exte
 
   private static final int SUM = DOUBLE_MSG_COUNT + BOOL_MSG_COUNT
       + INT_MSG_COUNT;
-  
+
   public static final String TMP_OUTPUT_PATH = "/tmp/messageQueue";
 
   public void testAvroMessenger() throws Exception {
     BSPMessageBundle<Writable> randomBundle = getRandomBundle();
     Configuration conf = new Configuration();
+    conf.set("hama.messenger.class",
+        "org.apache.hama.bsp.message.AvroMessageManagerImpl");
     conf.set(DiskQueue.DISK_QUEUE_PATH_KEY, TMP_OUTPUT_PATH);
     MessageManager<Writable> messageManager = MessageManagerFactory
         .getMessageManager(conf);



Mime
View raw message