svn commit: r1390805 - /hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestAvroMessageManager.java

[edwardyoon]

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);