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(