You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ho...@apache.org on 2025/08/25 02:31:49 UTC
(fluss) 05/06: [FIP-12] add dynamic config to enable lakehouse.
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 <lo...@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(