commit 32806e105ff5871451e605a5c3a28bac5e2df283
author Praveen Adlakha <praveen.adlakha@IM1314-L0.corp.inmobi.com> Fri Sep 08 12:52:14 2017 +0530
committer Pallavi Rao <pallavi.rao@inmobi.com> Fri Sep 08 12:52:28 2017 +0530
tree 5ab7247cce39e831dee22a2907922400b680700e
parent 84186f09e17aba7497be4a2bdec6f8b119405b0b

FALCON-2305 workflow metrics thread failures

Author: Praveen Adlakha <praveen.adlakha@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

(cherry picked from commit d07a2f7054d02b11842289911d4c82ed2a31aaa6)
Signed-off-by: Pallavi Rao <pallavi.rao@inmobi.com>

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 @@
                                         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 "