Bhupesh Chawda created APEXCORE-678: ---------------------------------------
Summary: Shutdown of application should start from input nodes Key: APEXCORE-678 URL: https://issues.apache.org/jira/browse/APEXCORE-678 Project: Apache Apex Core Issue Type: Bug Reporter: Bhupesh Chawda Assignee: Bhupesh Chawda Streaming container calls shutdown() for all nodes instead of just input nodes. ``` private void stopInputNodes() { for (Entry<Integer, Node<?>> e : nodes.entrySet()) { Node<?> node = e.getValue(); if (node instanceof InputNode) { final Thread thread = e.getValue().context.getThread(); if (thread == null || !thread.isAlive()) { continue; } } node.shutdown(true); } } ``` -- This message was sent by Atlassian JIRA (v6.3.15#6346)