Repository: sqoop Updated Branches: refs/heads/sqoop2 cbdf96544 -> 3fe009fb0
SQOOP-2279: Sqoop2: Clean connector cache after grant and revoke statements (Richard Zhou via Abraham Elmahrek) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/3fe009fb Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/3fe009fb Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/3fe009fb Branch: refs/heads/sqoop2 Commit: 3fe009fb03b0eead6775742683c810e6156fc9a2 Parents: cbdf965 Author: Abraham Elmahrek <[email protected]> Authored: Thu Apr 2 19:47:27 2015 -0700 Committer: Abraham Elmahrek <[email protected]> Committed: Thu Apr 2 19:47:27 2015 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java | 4 +--- .../src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java | 2 ++ .../java/org/apache/sqoop/shell/RevokePrivilegeFunction.java | 4 +--- .../src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java | 2 ++ 4 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/3fe009fb/shell/src/main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java ---------------------------------------------------------------------- diff --git a/shell/src/main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java b/shell/src/main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java index 27959d7..b7bb4b9 100644 --- a/shell/src/main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java +++ b/shell/src/main/java/org/apache/sqoop/shell/GrantPrivilegeFunction.java @@ -99,9 +99,7 @@ public class GrantPrivilegeFunction extends SqoopFunction { Arrays.asList(principalObject), Arrays.asList(privilegeObject)); - if (resourceType.toUpperCase().equals(MResource.TYPE.CONNECTOR.name())) { - client.clearCache(); - } + client.clearCache(); printlnResource(Constants.RES_GRANT_PRIVILEGE_SUCCESSFUL, action, resourceType + " " + resource, http://git-wip-us.apache.org/repos/asf/sqoop/blob/3fe009fb/shell/src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java ---------------------------------------------------------------------- diff --git a/shell/src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java b/shell/src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java index d1ae75e..2714e81 100644 --- a/shell/src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java +++ b/shell/src/main/java/org/apache/sqoop/shell/GrantRoleFunction.java @@ -75,6 +75,8 @@ public class GrantRoleFunction extends SqoopFunction { Arrays.asList(roleObject), Arrays.asList(principalObject)); + client.clearCache(); + printlnResource(Constants.RES_GRANT_ROLE_SUCCESSFUL, role, principalType + " " + principal); http://git-wip-us.apache.org/repos/asf/sqoop/blob/3fe009fb/shell/src/main/java/org/apache/sqoop/shell/RevokePrivilegeFunction.java ---------------------------------------------------------------------- diff --git a/shell/src/main/java/org/apache/sqoop/shell/RevokePrivilegeFunction.java b/shell/src/main/java/org/apache/sqoop/shell/RevokePrivilegeFunction.java index 0551b54..802d206 100644 --- a/shell/src/main/java/org/apache/sqoop/shell/RevokePrivilegeFunction.java +++ b/shell/src/main/java/org/apache/sqoop/shell/RevokePrivilegeFunction.java @@ -100,9 +100,7 @@ public class RevokePrivilegeFunction extends SqoopFunction { Arrays.asList(principalObject), Arrays.asList(privilegeObject)); - if (resourceType.toUpperCase().equals(MResource.TYPE.CONNECTOR.name())) { - client.clearCache(); - } + client.clearCache(); printlnResource(Constants.RES_REVOKE_PRIVILEGE_SUCCESSFUL, action, resourceType + " " + resource, http://git-wip-us.apache.org/repos/asf/sqoop/blob/3fe009fb/shell/src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java ---------------------------------------------------------------------- diff --git a/shell/src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java b/shell/src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java index 97afda2..8ce3518 100644 --- a/shell/src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java +++ b/shell/src/main/java/org/apache/sqoop/shell/RevokeRoleFunction.java @@ -75,6 +75,8 @@ public class RevokeRoleFunction extends SqoopFunction { Arrays.asList(roleObject), Arrays.asList(principalObject)); + client.clearCache(); + printlnResource(Constants.RES_REVOKE_ROLE_SUCCESSFUL, role, principalType + " " + principal);
