SENTRY-1751: HMSFollower should not persist empty full snapshot (Kalyan Kalvagadda, reviewed by: Na Li, Sergio Pena and Alex Kolbasov)
CDH-53908 Change-Id: I26626a4b397ad3c4a10414f3357f79f05f0d871b Reviewed-on: http://gerrit.sjc.cloudera.com:8080/22722 Tested-by: Jenkins User Reviewed-by: Kalyan Kumar Kalvagadda <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/sentry/repo Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/1c9014ee Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/1c9014ee Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/1c9014ee Branch: refs/for/cdh5-1.5.1_ha Commit: 1c9014eeaa755b55e5f052961d7db3b4cc855d6f Parents: 49cc480 Author: Alexander Kolbasov <[email protected]> Authored: Mon May 15 21:03:03 2017 -0700 Committer: Kalyan Kumar Kalvagadda <[email protected]> Committed: Wed May 17 17:22:06 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/sentry/service/thrift/HMSFollower.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sentry/blob/1c9014ee/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/service/thrift/HMSFollower.java ---------------------------------------------------------------------- diff --git a/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/service/thrift/HMSFollower.java b/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/service/thrift/HMSFollower.java index 5548ac0..7f9b706 100644 --- a/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/service/thrift/HMSFollower.java +++ b/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/service/thrift/HMSFollower.java @@ -290,6 +290,10 @@ public class HMSFollower implements Runnable, AutoCloseable { try { pathsFullSnapshot = fetchFullUpdate(); + if(pathsFullSnapshot.isEmpty()) { + LOGGER.info("Hive full snapshot is Empty. Perhaps, HMS does not have any data"); + return; + } } catch (ExecutionException | InterruptedException ex) { LOGGER.error("#### Encountered failure during fetching hive full snapshot !!", ex); return;
