This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 76e4c003c0b [bugfix](MultiPartition)let the user set the prefix of the
MultiPartition (#33820)
76e4c003c0b is described below
commit 76e4c003c0b5c1625c7e13e0dda3ef7aa13c6e5a
Author: lw112 <[email protected]>
AuthorDate: Sat Apr 20 20:38:53 2024 +0800
[bugfix](MultiPartition)let the user set the prefix of the MultiPartition
(#33820)
---
fe/fe-common/src/main/java/org/apache/doris/common/Config.java | 8 ++++++++
.../main/java/org/apache/doris/analysis/MultiPartitionDesc.java | 2 +-
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index 8bfe39ea990..a0eaf40f77c 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -1499,6 +1499,14 @@ public class Config extends ConfigBase {
@ConfField(mutable = true, masterOnly = true)
public static int max_dynamic_partition_num = 500;
+ /**
+ * Use this parameter to set the partition name prefix for multi partition,
+ * Only multi partition takes effect, not dynamic partitions.
+ * The default prefix is "p_".
+ */
+ @ConfField(mutable = true, masterOnly = true)
+ public static String multi_partition_name_prefix = "p_";
+
/**
* Used to limit the maximum number of partitions that can be created when
creating multi partition,
* to avoid creating too many partitions at one time.
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
index 76a47e18c60..b9e9bd1f4f0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
@@ -50,7 +50,6 @@ public class MultiPartitionDesc implements AllPartitionDesc {
- private final String partitionPrefix = "p_";
private LocalDateTime startTime;
private LocalDateTime endTime;
@@ -72,6 +71,7 @@ public class MultiPartitionDesc implements AllPartitionDesc {
TimestampArithmeticExpr.TimeUnit.YEAR
);
+ private final String partitionPrefix = Config.multi_partition_name_prefix;
private final Integer maxAllowedLimit = Config.max_multi_partition_num;
public MultiPartitionDesc(PartitionKeyDesc partitionKeyDesc,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
