[jira] [Commented] (APEXCORE-294) Graceful application shutdown

["Tushar Gosavi (JIRA)" <ji...@apache.org>]

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

Tushar Gosavi commented on APEXCORE-294:
----------------------------------------

would sending END_STREAM tuple from all input operators partition will work. Is there any other complication with this approach?
If this approach is fine I would start working on it.

The flow would be

- Master receives shutdown command from cli/rest api
- Master set shutdown on each container and send it as part of heartbeat response to all containers
- On receiving shutdown command StreamingContainer would mark alive false for all InputNode causing them to terminate
  with sending END_STREAM tuple downstream.

same could be achieve using operatorRequest for all input operator partition and this request will be handled by StreamingContainer to shutdown the input operator thread.


> Graceful application shutdown
> -----------------------------
>
>                 Key: APEXCORE-294
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-294
>             Project: Apache Apex Core
>          Issue Type: Improvement
>            Reporter: Thomas Weise
>
> By injecting the end stream tuple into input operators, to replace the current mechanism of forced operator undeploy.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)