diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/DynamicPartitionUtil.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/DynamicPartitionUtil.java index 4464473788..fe29dfe7ee 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/DynamicPartitionUtil.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/DynamicPartitionUtil.java @@ -636,7 +636,8 @@ public class DynamicPartitionUtil { // check replication_allocation first, then replciation_num ReplicaAllocation replicaAlloc = null; - if (properties.containsKey(DynamicPartitionProperty.REPLICATION_ALLOCATION)) { + if (!Config.force_olap_table_replication_allocation.isEmpty() + || properties.containsKey(DynamicPartitionProperty.REPLICATION_ALLOCATION)) { replicaAlloc = PropertyAnalyzer.analyzeReplicaAllocation(properties, "dynamic_partition"); properties.remove(DynamicPartitionProperty.REPLICATION_ALLOCATION); analyzedProperties.put(DynamicPartitionProperty.REPLICATION_ALLOCATION, replicaAlloc.toCreateStmt()); diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserPropertyMgr.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserPropertyMgr.java index aaeaa992ab..c9358734d9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserPropertyMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserPropertyMgr.java @@ -137,9 +137,10 @@ public class UserPropertyMgr implements Writable { Set tags = existProperty.getCopiedResourceTags(); // only root and admin can return empty tag. // empty tag means user can access all backends. - // for normal user, if tag is empty, use default tag. + // for normal user, if tag is empty and not set force_olap_table_replication_allocation, use default tag. if (tags.isEmpty() && !(qualifiedUser.equalsIgnoreCase(Auth.ROOT_USER) - || qualifiedUser.equalsIgnoreCase(Auth.ADMIN_USER))) { + || qualifiedUser.equalsIgnoreCase(Auth.ADMIN_USER)) + && Config.force_olap_table_replication_allocation.isEmpty()) { tags = Sets.newHashSet(Tag.DEFAULT_BACKEND_TAG); } return tags;