Repository: incubator-ranger Updated Branches: refs/heads/ranger-0.5 97cf9c396 -> de2f17ee7
RANGER-882 Add a catch all policy engine initialization to ensure that plugin will continue to pull policies periodically Project: http://git-wip-us.apache.org/repos/asf/incubator-ranger/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ranger/commit/de2f17ee Tree: http://git-wip-us.apache.org/repos/asf/incubator-ranger/tree/de2f17ee Diff: http://git-wip-us.apache.org/repos/asf/incubator-ranger/diff/de2f17ee Branch: refs/heads/ranger-0.5 Commit: de2f17ee72b454031c49eb8ca4487ec78ba2d88e Parents: 97cf9c3 Author: Alok Lal <[email protected]> Authored: Thu Mar 17 13:56:53 2016 -0700 Committer: Alok Lal <[email protected]> Committed: Thu Mar 17 13:56:53 2016 -0700 ---------------------------------------------------------------------- .../org/apache/ranger/plugin/service/RangerBasePlugin.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ranger/blob/de2f17ee/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java ---------------------------------------------------------------------- diff --git a/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java b/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java index 404108d..2afe0e6 100644 --- a/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java +++ b/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java @@ -107,9 +107,14 @@ public class RangerBasePlugin { } public void setPolicies(ServicePolicies policies) { - RangerPolicyEngine policyEngine = new RangerPolicyEngineImpl(policies, policyEngineOptions); + // guard against catastrophic failure during policy engine Initialization or + try { + RangerPolicyEngine policyEngine = new RangerPolicyEngineImpl(policies, policyEngineOptions); - this.policyEngine = policyEngine; + this.policyEngine = policyEngine; + } catch (Exception e) { + LOG.error("setPolicies: policy engine initialization failed! Leaving current policy engine as-is."); + } } public void cleanup() {
