You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by pa...@apache.org on 2017/09/08 07:22:21 UTC
falcon git commit: FALCON-2305 workflow metrics thread failures
Repository: falcon
Updated Branches:
refs/heads/master bfd1805ba -> d07a2f705
FALCON-2305 workflow metrics thread failures
Author: Praveen Adlakha <pr...@IM1314-L0.corp.inmobi.com>
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
Project: http://git-wip-us.apache.org/repos/asf/falcon/repo
Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/d07a2f70
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/d07a2f70
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/d07a2f70
Branch: refs/heads/master
Commit: d07a2f7054d02b11842289911d4c82ed2a31aaa6
Parents: bfd1805
Author: Praveen Adlakha <pr...@IM1314-L0.corp.inmobi.com>
Authored: Fri Sep 8 12:52:14 2017 +0530
Committer: Pallavi Rao <pa...@inmobi.com>
Committed: Fri Sep 8 12:52:14 2017 +0530
----------------------------------------------------------------------
.../falcon/service/BacklogMetricEmitterService.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/falcon/blob/d07a2f70/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 "