(paimon) branch master updated: [core] Remove catalog limitation in InitFileBasedPrivilegeProcedure

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new a987128fd [core] Remove catalog limitation in 
InitFileBasedPrivilegeProcedure
a987128fd is described below

commit a987128fd3135fcf83042390cdd17279c20fab92
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Mon Apr 29 20:38:53 2024 +0800

    [core] Remove catalog limitation in InitFileBasedPrivilegeProcedure
---
 .../procedure/privilege/InitFileBasedPrivilegeProcedure.java  | 11 -----------
 1 file changed, 11 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/privilege/InitFileBasedPrivilegeProcedure.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/privilege/InitFileBasedPrivilegeProcedure.java
index 7d71678a8..35d42ce32 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/privilege/InitFileBasedPrivilegeProcedure.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/privilege/InitFileBasedPrivilegeProcedure.java
@@ -26,9 +26,6 @@ import org.apache.paimon.privilege.PrivilegedCatalog;
 
 import org.apache.flink.table.procedure.ProcedureContext;
 
-import java.util.Arrays;
-import java.util.List;
-
 /**
  * Procedure to initialize file-based privilege system in warehouse. This 
procedure will
  * automatically create a root user with the provided password. Usage:
@@ -41,17 +38,9 @@ public class InitFileBasedPrivilegeProcedure extends 
ProcedureBase {
 
     public static final String IDENTIFIER = "init_file_based_privilege";
 
-    private static final List<String> SUPPORTED_CATALOGS =
-            Arrays.asList(
-                    "org.apache.paimon.catalog.FileSystemCatalog",
-                    "org.apache.paimon.hive.HiveCatalog");
-
     public String[] call(ProcedureContext procedureContext, String 
rootPassword) {
         if (catalog instanceof PrivilegedCatalog) {
             throw new IllegalArgumentException("Catalog is already a 
PrivilegedCatalog");
-        } else if (!SUPPORTED_CATALOGS.contains(catalog.getClass().getName())) 
{
-            throw new IllegalArgumentException(
-                    "File based privilege system does not support " + 
catalog.getClass().getName());
         }
 
         Options options = new Options(catalog.options());