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.
