Repository: sentry Updated Branches: refs/heads/master 985b70887 -> bd0583db9
SENTRY-2428: Skip null partitions or partitions with null sds entries (Arjun Mishra reviewed by Na Li) Change-Id: I3ad372400d482706f79d4570817e296332bb23c4 Project: http://git-wip-us.apache.org/repos/asf/sentry/repo Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/bd0583db Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/bd0583db Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/bd0583db Branch: refs/heads/master Commit: bd0583db9d52cfc03e8c75a3ac1eaac8fd535695 Parents: 985b708 Author: amishra <amis...@cloudera.com> Authored: Fri Oct 19 18:39:40 2018 -0500 Committer: amishra <amis...@cloudera.com> Committed: Fri Oct 19 18:39:40 2018 -0500 ---------------------------------------------------------------------- .../apache/sentry/service/thrift/FullUpdateInitializer.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sentry/blob/bd0583db/sentry-service/sentry-service-server/src/main/java/org/apache/sentry/service/thrift/FullUpdateInitializer.java ---------------------------------------------------------------------- diff --git a/sentry-service/sentry-service-server/src/main/java/org/apache/sentry/service/thrift/FullUpdateInitializer.java b/sentry-service/sentry-service-server/src/main/java/org/apache/sentry/service/thrift/FullUpdateInitializer.java index 3e27d1b..4ff3dc9 100644 --- a/sentry-service/sentry-service-server/src/main/java/org/apache/sentry/service/thrift/FullUpdateInitializer.java +++ b/sentry-service/sentry-service-server/src/main/java/org/apache/sentry/service/thrift/FullUpdateInitializer.java @@ -303,14 +303,13 @@ public final class FullUpdateInitializer implements AutoCloseable { Collection<String> partitionNames = new ArrayList<>(tblParts.size()); for (Partition part : tblParts) { - try { + if(part != null && part.getSd() != null) { String partPath = pathFromURI(part.getSd().getLocation()); if (partPath != null) { partitionNames.add(partPath.intern()); } - } catch(Exception e) { - LOGGER.error("Exception while fetching partitions for db = {} table = {}", dbName, tblName); - throw e; + } else { + LOGGER.info("Partition or its storage descriptor is null while fetching partitions for db = {} table = {}", dbName, tblName); } } return new ObjectMapping(authName, partitionNames);
