Thanks for the clarification, Edward.<br/><br/>What about the discrepancy in
the number of supersteps?<br/>Shouldn't it be 5 instead of 4?<br/><br/><br/>On
Friday, 20 December 2013, 16:48, Edward J. Yoon wrote:<br/>Hi
Jimmy,<br/><br/>The unconsumed messages are automatically removed from the
queue for<br/>next superstep. That's why getNumCurrentMessages() returns only
5.<br/><br/>We're thinking about adding persistent queue
-<br/>https://issues.apache.org/jira/browse/HAMA-734<br/><br/>Hope this
helps.<br/><br/><br/>On Fri, Dec 20, 2013 at 4:11 PM, Jimmy Ong
<[email protected]> wrote:<br/>> Hi,<br/>><br/>> I'm new to Hama and have a
seemingly dumb question:<br/>><br/>> Suppose I only have a single BSP task, why
does the following code result in having only 5 messages received by
peerId?<br/>><br/>> for(int i=0; j<5; i++) {<br/>><br/>> for(int j=0; j<5;
j++) {<br/>> peer.send(peerId, new IntWritable(1));<br/>> }<br/>>
peer.sync();<br/>><br/>> }<br/>><br/>> Even though the system reported as
having 25 messages sent and received, peerId.getNumCurrentMessages() returns
5.<br/>> Also, why is the total number of supersteps 4 and not 5 (this is
running in local mode, distributed is fine)?<br/>><br/>> Am I missing something
here?<br/>> Please kindly advise.<br/>><br/>> Thanks.<br/>><br/>><br/>>
13/12/20 15:03:30 INFO bsp.BSPJobClient: Current supersteps number: 4<br/>>
13/12/20 15:03:30 INFO bsp.BSPJobClient: The total number of supersteps:
4<br/>> 13/12/20 15:03:30 INFO bsp.BSPJobClient: Counters: 7<br/>> 13/12/20
15:03:30 INFO bsp.BSPJobClient:
org.apache.hama.bsp.JobInProgress$JobCounter<br/>> 13/12/20 15:03:30 INFO
bsp.BSPJobClient: SUPERSTEPS=4<br/>> 13/12/20 15:03:30 INFO
bsp.BSPJobClient: LAUNCHED_TASKS=1<br/>> 13/12/20 15:03:30 INFO
bsp.BSPJobClient: org.apache.hama.bsp.BSPPeerImpl$PeerCounter<br/>> 13/12/20
15:03:30 INFO bsp.BSPJobClient:
SUPERSTEP_SUM=5<br/>> 13/12/20 15:03:30 INFO bsp.BSPJobClient:
TIME_IN_SYNC_MS=0<br/>> 13/12/20 15:03:30 INFO bsp.BSPJobClient:
TOTAL_MESSAGES_SENT=25<br/>> 13/12/20 15:03:30 INFO bsp.BSPJobClient:
TOTAL_MESSAGES_RECEIVED=25<br/>> 13/12/20 15:03:30 INFO bsp.BSPJobClient:
TASK_OUTPUT_RECORDS=1<br/><br/><br/><br/><br/>-- <br/>Best Regards, Edward J.
Yoon<br/>@eddieyoon<br/><br/><br/><br/><a
href="http://overview.mail.yahoo.com?.src=iOS";><br/><br/>Sent from Yahoo Mail
for iPhone</a>
