incubator-hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward J. Yoon (Created) (JIRA)" <>
Subject [jira] [Created] (HAMA-469) The statusUpdate() method should be called finally.
Date Mon, 07 Nov 2011 11:03:51 GMT
The statusUpdate() method should be called finally.

                 Key: HAMA-469
             Project: Hama
          Issue Type: Bug
            Reporter: Edward J. Yoon
            Priority: Minor

  public void sync() throws InterruptedException {
    try {
      Iterator<Entry<InetSocketAddress, LinkedList<BSPMessage>>> it = messenger

      while (it.hasNext()) {
        Entry<InetSocketAddress, LinkedList<BSPMessage>> entry =;
        final InetSocketAddress addr = entry.getKey();
        final Iterable<BSPMessage> messages = entry.getValue();

        final BSPMessageBundle bundle = combineMessages(messages);

        if (conf.getBoolean("bsp.checkpoint.enabled", false)) {
          checkpoint(checkpointedPath(), bundle);

        // remove this message during runtime to save a bit of memory

        messenger.transfer(addr, bundle);

      umbilical.statusUpdate(taskId, currentTaskStatus);

      // Clear outgoing queues.

    } catch (Exception e) {
          "Caught exception during superstep "
              + currentTaskStatus.getSuperstepCount() + "!", e);

I think, the task status should be set to "Failed" when exception occurs in the sync() method.
And the statusUpdate() method should be called finally.

This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:!default.jspa
For more information on JIRA, see:


View raw message