Repository: oodt Updated Branches: refs/heads/feature/zookeeper-config e59e77c1a -> a1a96fb39
safe guard in cases where there are no topN products coming back Project: http://git-wip-us.apache.org/repos/asf/oodt/repo Commit: http://git-wip-us.apache.org/repos/asf/oodt/commit/3d0a241f Tree: http://git-wip-us.apache.org/repos/asf/oodt/tree/3d0a241f Diff: http://git-wip-us.apache.org/repos/asf/oodt/diff/3d0a241f Branch: refs/heads/feature/zookeeper-config Commit: 3d0a241f14bda572ed3c63b68fb625a7f85d99e2 Parents: 7616e00 Author: Chris Mattmann <[email protected]> Authored: Thu Jul 20 22:30:23 2017 -0700 Committer: Chris Mattmann <[email protected]> Committed: Thu Jul 20 22:30:23 2017 -0700 ---------------------------------------------------------------------- .../apache/oodt/pcs/services/HealthResource.java | 18 +++++++++++------- 1 file changed, 11 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oodt/blob/3d0a241f/pcs/services/src/main/java/org/apache/oodt/pcs/services/HealthResource.java ---------------------------------------------------------------------- diff --git a/pcs/services/src/main/java/org/apache/oodt/pcs/services/HealthResource.java b/pcs/services/src/main/java/org/apache/oodt/pcs/services/HealthResource.java index b2d9b8d..80eadfb 100644 --- a/pcs/services/src/main/java/org/apache/oodt/pcs/services/HealthResource.java +++ b/pcs/services/src/main/java/org/apache/oodt/pcs/services/HealthResource.java @@ -299,13 +299,17 @@ public class HealthResource extends PCSService { Map<String, Object> latestFilesOutput = new ConcurrentHashMap<String, Object>(); latestFilesOutput.put("topN", PCSHealthMonitor.TOP_N_PRODUCTS); List<Object> latestFilesList = new Vector<Object>(); - for (Product prod : (List<Product>) (List<?>) report - .getLatestProductsIngested()) { - try { - this.encodeLatestFile(latestFilesList, prod); - } catch (MalformedURLException e) { - LOG.log(Level.WARNING, "Unable to encode latest file: [" - + prod.getProductName() + "]: error: Message: " + e.getMessage()); + if (report != null && + report.getLatestProductsIngested() != null && + report.getLatestProductsIngested().size() > 0){ + for (Product prod : (List<Product>) (List<?>) report + .getLatestProductsIngested()) { + try { + this.encodeLatestFile(latestFilesList, prod); + } catch (MalformedURLException e) { + LOG.log(Level.WARNING, "Unable to encode latest file: [" + + prod.getProductName() + "]: error: Message: " + e.getMessage()); + } } } latestFilesOutput.put("files", latestFilesList);
