Dear Community, I have changed the implementaion plan based on PR comments. Following is the new proposal for this feature.
https://docs.google.com/a/datatorrent.com/document/d/1hSLH4xi_15OWwW4KY7--LU3e2iHHhfthOpATicnC5eE/edit?usp=sharing Please provide the feedback. I will update the PR accrodinly. - Tushar. On Fri, Nov 25, 2016 at 4:40 PM, Tushar Gosavi <tus...@datatorrent.com> wrote: > Dear Community, > > I have open an pull request for shutting down application by sending > END_STREAM control tuples from all input operator. This is similar to > all input operator have stopped after raising ShutdownException. > > On receiving shutdown request, master will prepare OPERATOR_STOP > command for all input partitions, and send it to container as part of > heartbeat response to container. Container will shutdown the operator > thread after receiving this command. > > https://github.com/apache/apex-core/pull/424 > Please review. > > Thanks, > - Tushar.
