[
https://issues.apache.org/jira/browse/HAMA-707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13637496#comment-13637496
]
Hudson commented on HAMA-707:
-----------------------------
Integrated in Hama-Nightly #891 (See
[https://builds.apache.org/job/Hama-Nightly/891/])
Fixes for [HAMA-707] and [HAMA-722] (Revision 1470171)
Result = SUCCESS
surajsmenon :
Files :
* /hama/trunk/CHANGES.txt
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
* /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageManager.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/MessageTransferQueueFactory.java
* /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/BSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/ByteBufferBSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/HeapByteArrayBSPMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/POJOMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/bundle/WritableMessageBundle.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/io/SpillingDataOutputBuffer.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/BSPMessageInterface.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/ByteArrayMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskTransferProtocolQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MemoryQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MemoryTransferProtocol.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/MessageTransferQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/POJOMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SingleLockQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SortedMessageQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueue.java
*
/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/SpillingQueueTransferProtocol.java
*
/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestHadoopMessageManager.java
*
/hama/trunk/core/src/test/java/org/apache/hama/bsp/message/TestMessageBundle.java
> BSPMessageBundle should be able to encapsulate messages serialized in
> ByteBuffer
> --------------------------------------------------------------------------------
>
> Key: HAMA-707
> URL: https://issues.apache.org/jira/browse/HAMA-707
> Project: Hama
> Issue Type: Improvement
> Reporter: Suraj Menon
> Assignee: Suraj Menon
> Fix For: 0.7.0
>
> Attachments: HAMA-707.patch
>
>
> BSPMessageBundle reads out all the messages from the queue and creates an in
> memory list before sending it to peer. This does not work when all messages
> could not be kept in memory. In case of spilling queue, where the messages
> are already serialized, avoid complete read out of messages.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
