[ 
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)

Reply via email to