Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 29E57200CD4 for ; Sat, 15 Jul 2017 00:51:09 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2835D16EAB9; Fri, 14 Jul 2017 22:51:09 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 6ECD616EAB7 for ; Sat, 15 Jul 2017 00:51:08 +0200 (CEST) Received: (qmail 89166 invoked by uid 500); 14 Jul 2017 22:51:07 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 89150 invoked by uid 99); 14 Jul 2017 22:51:07 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 14 Jul 2017 22:51:07 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 0A9B91A0354 for ; Fri, 14 Jul 2017 22:51:07 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -99.202 X-Spam-Level: X-Spam-Status: No, score=-99.202 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 1zNQ4e6mbONt for ; Fri, 14 Jul 2017 22:51:06 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 797D95F6C6 for ; Fri, 14 Jul 2017 22:51:05 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 3BB67E0641 for ; Fri, 14 Jul 2017 22:51:04 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 2F4312475D for ; Fri, 14 Jul 2017 22:51:02 +0000 (UTC) Date: Fri, 14 Jul 2017 22:51:02 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: dev@apex.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (APEXCORE-734) StramLocalCluster may not terminate properly MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 14 Jul 2017 22:51:09 -0000 [ https://issues.apache.org/jira/browse/APEXCORE-734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16088239#comment-16088239 ] ASF GitHub Bot commented on APEXCORE-734: ----------------------------------------- PramodSSImmaneni commented on issue #532: APEXCORE-734 StramLocalCluster may not terminate properly URL: https://github.com/apache/apex-core/pull/532#issuecomment-315485744 Can you rebase ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org > StramLocalCluster may not terminate properly > -------------------------------------------- > > Key: APEXCORE-734 > URL: https://issues.apache.org/jira/browse/APEXCORE-734 > Project: Apache Apex Core > Issue Type: Improvement > Reporter: Vlad Rozov > Assignee: Vlad Rozov > > When StramLocalCluster is run asynchronously it may be shutdown during StramLocalCluster initialization leading to termination without performing necessary termination sequence. Runtime exception during the run may also lead to improper termination sequence. For example: > {noformat} > Exception in thread "master" java.lang.RuntimeException: java.lang.InterruptedException > at com.datatorrent.bufferserver.server.Server.run(Server.java:154) > at com.datatorrent.stram.StramLocalCluster.run(StramLocalCluster.java:474) > at com.datatorrent.stram.StramLocalCluster.run(StramLocalCluster.java:459) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.InterruptedException > at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1302) > at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231) > at com.datatorrent.bufferserver.server.Server.run(Server.java:152) > ... 3 more > {noformat} -- This message was sent by Atlassian JIRA (v6.4.14#64029)