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 E296E200CFE for ; Fri, 8 Sep 2017 09:22:36 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E15371609C0; Fri, 8 Sep 2017 07:22:36 +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 4160C1609A7 for ; Fri, 8 Sep 2017 09:22:36 +0200 (CEST) Received: (qmail 61288 invoked by uid 500); 8 Sep 2017 07:22:35 -0000 Mailing-List: contact commits-help@falcon.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@falcon.apache.org Delivered-To: mailing list commits@falcon.apache.org Received: (qmail 61279 invoked by uid 99); 8 Sep 2017 07:22:35 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 Sep 2017 07:22:35 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 39079F5568; Fri, 8 Sep 2017 07:22:35 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: pallavi@apache.org To: commits@falcon.apache.org Message-Id: <50707b40805e4e4889c68d7e5cdccb21@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: falcon git commit: FALCON-2305 workflow metrics thread failures Date: Fri, 8 Sep 2017 07:22:35 +0000 (UTC) archived-at: Fri, 08 Sep 2017 07:22:37 -0000 Repository: falcon Updated Branches: refs/heads/0.11 84186f09e -> 32806e105 FALCON-2305 workflow metrics thread failures Author: Praveen Adlakha Reviewers: @pallavi, @peeyushb Closes #388 from PraveenAdlakha/2305 and squashes the following commits: beed4f9c6 [Praveen Adlakha] checkstyle issue fixed f2fe99f3b [Praveen Adlakha] FALCON-2305 Handle workflow Thread Failure c917fb47b [Praveen Adlakha] comments addressed (cherry picked from commit d07a2f7054d02b11842289911d4c82ed2a31aaa6) Signed-off-by: Pallavi Rao Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/32806e10 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/32806e10 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/32806e10 Branch: refs/heads/0.11 Commit: 32806e105ff5871451e605a5c3a28bac5e2df283 Parents: 84186f0 Author: Praveen Adlakha Authored: Fri Sep 8 12:52:14 2017 +0530 Committer: Pallavi Rao Committed: Fri Sep 8 12:52:28 2017 +0530 ---------------------------------------------------------------------- .../falcon/service/BacklogMetricEmitterService.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/32806e10/prism/src/main/java/org/apache/falcon/service/BacklogMetricEmitterService.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/service/BacklogMetricEmitterService.java b/prism/src/main/java/org/apache/falcon/service/BacklogMetricEmitterService.java index 50170b9..aa1c346 100644 --- a/prism/src/main/java/org/apache/falcon/service/BacklogMetricEmitterService.java +++ b/prism/src/main/java/org/apache/falcon/service/BacklogMetricEmitterService.java @@ -417,9 +417,14 @@ public final class BacklogMetricEmitterService implements FalconService, iterator.remove(); continue; } - InstancesResult status = wfEngine.getStatus(entity, nominalTime, - new Date(nominalTime.getTime() + 200), PROCESS_LIFE_CYCLE, false); - if (status.getInstances().length > 0 + InstancesResult status = null; + try { + status = wfEngine.getStatus(entity, nominalTime, + new Date(nominalTime.getTime() + 200), PROCESS_LIFE_CYCLE, false); + } catch (FalconException e) { + LOG.error("Unable to get status for :" + entity.getName(), e); + } + if (status !=null && status.getInstances().length > 0 && status.getInstances()[0].status == InstancesResult. WorkflowStatus.SUCCEEDED) { LOG.debug("Instance of nominal time {} of entity {} has succeeded, removing "