hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward J. Yoon (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (HAMA-833) Add more finish states for vertices
Date Tue, 24 Dec 2013 00:41:51 GMT

    [ https://issues.apache.org/jira/browse/HAMA-833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13856056#comment-13856056

Edward J. Yoon commented on HAMA-833:

{quote}Exactly, but i mention again that this only happens at the very next aggregation phase
after the vertex has halted. After that one, they are excluded as expected.{quote}

That's why I ask again. The "Aggregator" aggregates the value of *all* vertices[1]. It doesn't
matter at all whether active or inactive. AverageAggregator should returns the average of
all vertices, SumAggregator should returns the sum of all vertices. Min or Max is the same.
Otherwise, it will affect the user's graph algorithm itself. The system bug I mentioned, is
that aggregated value has changed.

1. http://svn.apache.org/repos/asf/hama/trunk/graph/src/main/java/org/apache/hama/graph/Aggregator.java

{quote}So, what's the status of this issue?{quote}

I don't see any relation between the reported issue and this ticket. I'd like to close this

Instead, to support aggregation for activated vertices, we can introduce the custom aggregator
that can be used within Vertex like below: 

    aggregate(MY_AGG, new DoubleWritable(1));
 } else {


> Add more finish states for vertices
> -----------------------------------
>                 Key: HAMA-833
>                 URL: https://issues.apache.org/jira/browse/HAMA-833
>             Project: Hama
>          Issue Type: Improvement
>          Components: graph
>    Affects Versions: 0.6.3
>            Reporter: Anastasis Andronidis
>            Assignee: Anastasis Andronidis
>            Priority: Minor
>              Labels: features
>             Fix For: 0.7.0
> We should handle more cases on the vertices, like:
> 1) voteToStop() : Immediately stop the vertex compute and suppress any further calculations
on top of that. (e.g. aggregation)
> 2) voteToTerminate(): Immediately stop the vertex compute, suppress any further calculations
on top of that and deactivate the vertex so even if any message reaches it, will not come
> Any comments?

This message was sent by Atlassian JIRA

View raw message