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

hongshun pushed a commit to branch dlf-2.5
in repository https://gitbox.apache.org/repos/asf/fluss.git

commit d9c40d99e453444207a75b02c071f8b382e438ef
Author: Hongshun Wang <loserwang1...@gmail.com>
AuthorDate: Wed Aug 20 09:38:00 2025 +0800

    [FIP-12] add dynamic config to enable lakehouse.
---
 .../alibaba/fluss/security/acl/OperationType.java  |  3 +-
 .../server/authorizer/DefaultAuthorizerTest.java   | 38 ++++++++++------------
 2 files changed, 18 insertions(+), 23 deletions(-)

diff --git 
a/fluss-common/src/main/java/com/alibaba/fluss/security/acl/OperationType.java 
b/fluss-common/src/main/java/com/alibaba/fluss/security/acl/OperationType.java
index 2b17c8411..efb372c14 100644
--- 
a/fluss-common/src/main/java/com/alibaba/fluss/security/acl/OperationType.java
+++ 
b/fluss-common/src/main/java/com/alibaba/fluss/security/acl/OperationType.java
@@ -43,8 +43,7 @@ public enum OperationType {
     ALTER((byte) 7),
     DESCRIBE((byte) 8),
     DESCRIBE_CONFIGS((byte) 9),
-    ALTER_CONFIGS((byte) 10),
-    UNKNOWN((byte) -1);
+    ALTER_CONFIGS((byte) 10);
 
     private final byte code;
 
diff --git 
a/fluss-server/src/test/java/com/alibaba/fluss/server/authorizer/DefaultAuthorizerTest.java
 
b/fluss-server/src/test/java/com/alibaba/fluss/server/authorizer/DefaultAuthorizerTest.java
index 0f2816a6c..5a5956869 100644
--- 
a/fluss-server/src/test/java/com/alibaba/fluss/server/authorizer/DefaultAuthorizerTest.java
+++ 
b/fluss-server/src/test/java/com/alibaba/fluss/server/authorizer/DefaultAuthorizerTest.java
@@ -58,7 +58,11 @@ import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
+import static com.alibaba.fluss.security.acl.OperationType.ALTER;
+import static com.alibaba.fluss.security.acl.OperationType.ALTER_CONFIGS;
 import static com.alibaba.fluss.security.acl.OperationType.CREATE;
+import static com.alibaba.fluss.security.acl.OperationType.DESCRIBE;
+import static com.alibaba.fluss.security.acl.OperationType.DESCRIBE_CONFIGS;
 import static com.alibaba.fluss.security.acl.OperationType.DROP;
 import static com.alibaba.fluss.security.acl.OperationType.READ;
 import static com.alibaba.fluss.security.acl.OperationType.WRITE;
@@ -281,37 +285,29 @@ public class DefaultAuthorizerTest {
                 Arrays.asList(
                         READ,
                         WRITE,
-                        OperationType.CREATE,
-                        OperationType.DROP,
-                        OperationType.ALTER,
-                        OperationType.DESCRIBE));
+                        CREATE,
+                        DROP,
+                        ALTER,
+                        DESCRIBE,
+                        ALTER_CONFIGS,
+                        DESCRIBE_CONFIGS));
         testOperationTypeImplicationsOfAllow(
-                Resource.cluster(),
-                OperationType.CREATE,
-                Collections.singleton(OperationType.DESCRIBE));
+                Resource.cluster(), OperationType.CREATE, 
Collections.singleton(DESCRIBE));
         testOperationTypeImplicationsOfAllow(
-                Resource.cluster(),
-                OperationType.DROP,
-                Collections.singleton(OperationType.DESCRIBE));
+                Resource.cluster(), OperationType.DROP, 
Collections.singleton(DESCRIBE));
         testOperationTypeImplicationsOfAllow(
-                Resource.cluster(),
-                OperationType.ALTER,
-                Collections.singleton(OperationType.DESCRIBE));
+                Resource.cluster(), ALTER, Collections.singleton(DESCRIBE));
 
         // when we allow READ on any resource, we also allow DESCRIBE and 
FILESYSTEM_TOKEN on
         // cluster.
         testOperationTypeImplicationsOfAllow(
-                Resource.cluster(), READ, 
Collections.singletonList(OperationType.DESCRIBE));
+                Resource.cluster(), READ, Collections.singletonList(DESCRIBE));
         testOperationTypeImplicationsOfAllow(
-                Resource.cluster(), WRITE, 
Collections.singletonList(OperationType.DESCRIBE));
+                Resource.cluster(), WRITE, 
Collections.singletonList(DESCRIBE));
         testOperationTypeImplicationsOfAllow(
-                Resource.database("database1"),
-                READ,
-                Collections.singletonList(OperationType.DESCRIBE));
+                Resource.database("database1"), READ, 
Collections.singletonList(DESCRIBE));
         testOperationTypeImplicationsOfAllow(
-                Resource.table("database2", "table1"),
-                WRITE,
-                Collections.singletonList(OperationType.DESCRIBE));
+                Resource.table("database2", "table1"), WRITE, 
Collections.singletonList(DESCRIBE));
     }
 
     private void testOperationTypeImplicationsOfAllow(

Reply via email to