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(
