apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tushar Gosavi (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXCORE-294) Graceful application shutdown
Date Tue, 15 Nov 2016 05:47:59 GMT

    [ 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

View raw message