giraph-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hudson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GIRAPH-45) Improve the way to keep outgoing messages
Date Sun, 05 Aug 2012 01:00:21 GMT

    [ https://issues.apache.org/jira/browse/GIRAPH-45?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13428763#comment-13428763
] 

Hudson commented on GIRAPH-45:
------------------------------

Integrated in Giraph-trunk-Commit #153 (See [https://builds.apache.org/job/Giraph-trunk-Commit/153/])
    GIRAPH-45: Improve the way to keep outgoing messages (majakabiljo via
aching). (Revision 1369508)

     Result = FAILURE
aching : http://svn.apache.org/viewcvs.cgi/?root=Apache-SVN&view=rev&rev=1369508
Files : 
* /giraph/trunk/CHANGELOG
* /giraph/trunk/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/NettyServer.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClientServer.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerServer.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/RPCCommunications.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/RequestRegistry.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/SendPartitionMessagesRequest.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/ServerData.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/WorkerServer.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/BasicMessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/DiskBackedMessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/DiskBackedMessageStoreByPartition.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/FlushableMessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/MessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/MessageStoreByPartition.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/MessageStoreFactory.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/SendPartitionCurrentMessagesRequest.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/SequentialFileMessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/SimpleMessageStore.java
* /giraph/trunk/src/main/java/org/apache/giraph/comm/messages/package-info.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/BasicVertexResolver.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceWorker.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/GiraphJob.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/VertexResolver.java
* /giraph/trunk/src/main/java/org/apache/giraph/graph/partition/Partition.java
* /giraph/trunk/src/main/java/org/apache/giraph/utils/CollectionUtils.java
* /giraph/trunk/src/test/java/org/apache/giraph/comm/ConnectionTest.java
* /giraph/trunk/src/test/java/org/apache/giraph/comm/RequestTest.java
* /giraph/trunk/src/test/java/org/apache/giraph/comm/TestMessageStores.java
* /giraph/trunk/src/test/java/org/apache/giraph/utils/MockUtils.java

                
> Improve the way to keep outgoing messages
> -----------------------------------------
>
>                 Key: GIRAPH-45
>                 URL: https://issues.apache.org/jira/browse/GIRAPH-45
>             Project: Giraph
>          Issue Type: Improvement
>          Components: bsp
>            Reporter: Hyunsik Choi
>            Assignee: Maja Kabiljo
>         Attachments: GIRAPH-45-1.patch, GIRAPH-45-2.patch, GIRAPH-45-3.patch, GIRAPH-45.diff
>
>
> As discussed in GIRAPH-12(http://goo.gl/CE32U), I think that there is a potential problem
to cause out of memory when the rate of message generation is higher than the rate of message
flush (or network bandwidth).
> To overcome this problem, we need more eager strategy for message flushing or some approach
to spill messages into disk.
> The below link is Dmitriy's suggestion.
> https://issues.apache.org/jira/browse/GIRAPH-12?focusedCommentId=13116253&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13116253

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message