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
ticket.

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

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

WDYT?

> 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
alive.
> Any comments?



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Mime
View raw message