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