tajo-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jihoon Son (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (TAJO-274) Maintaining connectivity to Tajo master even though the restart of the Tajo master
Date Fri, 25 Oct 2013 02:42:03 GMT

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

Jihoon Son commented on TAJO-274:
---------------------------------

Thanks for your contribution, 
but this patch some strange codes like this.

{code}
In TajoWorker
private void connectToTajoMaster(String tajoMasterAddrString) {
  LOG.info("Connecting to TajoMaster (" + tajoMasterAddrString +")");
  this.tajoMasterAddress = NetUtils.createSocketAddr(tajoMasterAddrString);

  while(true) {
    try {
//        tajoMasterRpc = new AsyncRpcClient(TajoMasterProtocol.class, this.tajoMasterAddress);
//        tajoMasterRpcClient = tajoMasterRpc.getStub();
      break;
    } catch (Exception e) {
      LOG.error("Can't connect to TajoMaster[" + NetUtils.normalizeInetSocketAddress(tajoMasterAddress)
+ "], "
          + e.getMessage(), e);
    }
     try {
      Thread.sleep(3000);
    } catch (InterruptedException e) {
    }
  }
}
{code}

> Maintaining connectivity to Tajo master even though the restart of the Tajo master
> ----------------------------------------------------------------------------------
>
>                 Key: TAJO-274
>                 URL: https://issues.apache.org/jira/browse/TAJO-274
>             Project: Tajo
>          Issue Type: Improvement
>            Reporter: Keuntae Park
>         Attachments: TAJO-274.patch
>
>
> Currently, when you restart the Tajo master, you should restart all the workers and clients
also.
> When client or worker has problem with connection to Tajo master due to the master restart,
it needs to close the previous connection and try to reconnect to the master



--
This message was sent by Atlassian JIRA
(v6.1#6144)

Mime
View raw message