hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ilias Kapouranis (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (HAMA-833) Add more finish states for vertices
Date Mon, 23 Dec 2013 12:50:50 GMT

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

Ilias Kapouranis commented on HAMA-833:
---------------------------------------

if(getSuperstepCount() == 1){
	if(getVertexID().toString().equals("1")){
		voteToHalt();
	}
} else if(getSuperstepCount() == 2){
	System.out.println(getNumLastAggregatedVertices(0));
} else if(getSuperstepCount() == 3){
	System.out.println(getNumLastAggregatedVertices(0));
} 

So here we choose the vertex with id 1 to halt. At superstep 2 and 3 we print the number of
vertices that were aggregated before each superstep.
If we insert 10 nodes, at superstep 2 we will see that it prints 10. This means that even
though the node halted, it was aggregated! But then at superstep 3, we will see that the number
goes to 9.

> 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