Repository: sqoop
Updated Branches:
  refs/heads/branch-1.99.6 0c06834db -> ea5aa9c2d


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/ea5aa9c2
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/ea5aa9c2
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/ea5aa9c2

Branch: refs/heads/branch-1.99.6
Commit: ea5aa9c2d6258bb0491ac53abf31514b3b9dde5a
Parents: 0c06834
Author: Abraham Elmahrek <[email protected]>
Authored: Thu Apr 2 19:47:27 2015 -0700
Committer: Abraham Elmahrek <[email protected]>
Committed: Thu Apr 2 20:03:23 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/ea5aa9c2/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/ea5aa9c2/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/ea5aa9c2/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/ea5aa9c2/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);
 

Reply via email to