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 2013/07/14 15:50:02 UTC
svn commit: r1502975 -
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java
Author: edwardyoon
Date: Sun Jul 14 13:50:02 2013
New Revision: 1502975
URL: http://svn.apache.org/r1502975
Log: (empty)
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java
Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java?rev=1502975&r1=1502974&r2=1502975&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java Sun Jul 14 13:50:02 2013
@@ -81,8 +81,10 @@ public class MessageTransferQueueFactory
public static MessageTransferQueue getMessageTransferQueue(Configuration conf) {
if (conf.getClass(MessageManager.QUEUE_TYPE_CLASS, null) != null) {
- LOG.warn("Message queue is configured on deprecated parameter:"
- + MessageManager.QUEUE_TYPE_CLASS);
+ // TODO print only once -- Ed
+
+ // LOG.warn("Message queue is configured on deprecated parameter:"
+ // + MessageManager.QUEUE_TYPE_CLASS);
return new BackwardCompatibleTransferQueue();
}
return (MessageTransferQueue) ReflectionUtils.newInstance(conf.getClass(