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