Mailing-List: contact dev-help@apex.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@apex.apache.org
Date: Wed, 22 Mar 2017 11:59:41 +0000 (UTC)
From: "Bhupesh Chawda (JIRA)" <jira@apache.org>
To: dev@apex.incubator.apache.org
Message-ID: <JIRA.13058200.1490183922000.87444.1490183981608@Atlassian.JIRA>
In-Reply-To: <JIRA.13058200.1490183922000@Atlassian.JIRA>
References: <JIRA.13058200.1490183922000@Atlassian.JIRA> <JIRA.13058200.1490183922232@jira-lw-us.apache.org>
Subject: [jira] [Updated] (APEXCORE-678) Shutdown of application should
 start from input nodes
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Wed, 22 Mar 2017 11:59:45 -0000


     [ https://issues.apache.org/jira/browse/APEXCORE-678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bhupesh Chawda updated APEXCORE-678:
------------------------------------
    Description: 
Streaming container calls shutdown() for all nodes instead of just input nodes.

{code}
  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);
    }
  }
{code}

  was:
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);
    }
  }
```


> 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.
> {code}
>   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);
>     }
>   }
> {code}


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)