diff --git a/core/src/test/java/org/apache/gravitino/connector/authorization/mysql/TestMySQLAuthorization.java b/core/src/test/java/org/apache/gravitino/connector/authorization/mysql/TestMySQLAuthorization.java index db7c629bbd5..e8d747da11f 100644 --- a/core/src/test/java/org/apache/gravitino/connector/authorization/mysql/TestMySQLAuthorization.java +++ b/core/src/test/java/org/apache/gravitino/connector/authorization/mysql/TestMySQLAuthorization.java @@ -32,7 +32,7 @@ public String shortName() { } @Override - protected AuthorizationPlugin newPlugin( + public AuthorizationPlugin newPlugin( String metalake, String catalogProvider, Map config) { return new TestMySQLAuthorizationPlugin(); } diff --git a/core/src/test/java/org/apache/gravitino/connector/authorization/ranger/TestRangerAuthorization.java b/core/src/test/java/org/apache/gravitino/connector/authorization/ranger/TestRangerAuthorization.java index 1709c90319f..9df9a8d63b7 100644 --- a/core/src/test/java/org/apache/gravitino/connector/authorization/ranger/TestRangerAuthorization.java +++ b/core/src/test/java/org/apache/gravitino/connector/authorization/ranger/TestRangerAuthorization.java @@ -18,7 +18,6 @@ */ package org.apache.gravitino.connector.authorization.ranger; -import com.google.common.base.Preconditions; import java.util.Map; import org.apache.gravitino.connector.authorization.AuthorizationPlugin; import org.apache.gravitino.connector.authorization.BaseAuthorization; @@ -29,23 +28,12 @@ public TestRangerAuthorization() {} @Override public String shortName() { - return "test-ranger"; + return "ranger"; } @Override public AuthorizationPlugin newPlugin( - String metalake, String catalogProvider, Map properties) { - Preconditions.checkArgument( - properties.containsKey("authorization.ranger.service.type"), - String.format("%s is required", "authorization.ranger.service.type")); - String serviceType = properties.get("authorization.ranger.service.type").toUpperCase(); - switch (serviceType) { - case "HADOOPSQL": - return new TestRangerAuthorizationHadoopSQLPlugin(); - case "HDFS": - return new TestRangerAuthorizationHDFSPlugin(); - default: - throw new IllegalArgumentException("Unsupported service type: " + serviceType); - } + String metalake, String catalogProvider, Map config) { + return new TestRangerAuthorizationPlugin(); } }