This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 79a610ec7f2 [revert](storage) storage medium of partition should not
inherit from table (#41192)
79a610ec7f2 is described below
commit 79a610ec7f2a6fde8cda24a5f4b891c3e983762f
Author: zhangdong <493738...@qq.com>
AuthorDate: Tue Sep 24 14:35:21 2024 +0800
[revert](storage) storage medium of partition should not inherit from table
(#41192)
revert #35644
table if not set storage medium, will set default by
`Config.default_storage_medium`,
at present, we cannot distinguish whether the storage medium of the
table is set by the user.
If it is not set by the user, it represents priority use rather than
mandatory use. If we directly inherit the storage medium of the table,
it may cause the partition to be forced to use 'Config.
default_storage_madium', resulting in the partition being unable to be
created
---
.../src/main/java/org/apache/doris/datasource/InternalCatalog.java | 7 -------
regression-test/suites/mtmv_p0/test_storage_medium_mtmv.groovy | 2 ++
2 files changed, 2 insertions(+), 7 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 033af006dd8..4edf61d8342 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -1663,13 +1663,6 @@ public class InternalCatalog implements
CatalogIf<Database> {
if
(!properties.containsKey(PropertyAnalyzer.PROPERTIES_STORAGE_POLICY)) {
properties.put(PropertyAnalyzer.PROPERTIES_STORAGE_POLICY,
olapTable.getStoragePolicy());
}
- if
(!properties.containsKey(PropertyAnalyzer.PROPERTIES_STORAGE_MEDIUM)) {
- TStorageMedium tableStorageMedium =
olapTable.getStorageMedium();
- if (tableStorageMedium != null) {
- properties.put(PropertyAnalyzer.PROPERTIES_STORAGE_MEDIUM,
- tableStorageMedium.name().toLowerCase());
- }
- }
singlePartitionDesc.analyze(partitionInfo.getPartitionColumns().size(),
properties);
partitionInfo.createAndCheckPartitionItem(singlePartitionDesc,
isTempPartition);
diff --git a/regression-test/suites/mtmv_p0/test_storage_medium_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_storage_medium_mtmv.groovy
index 59116eb264e..0432245d808 100644
--- a/regression-test/suites/mtmv_p0/test_storage_medium_mtmv.groovy
+++ b/regression-test/suites/mtmv_p0/test_storage_medium_mtmv.groovy
@@ -18,6 +18,8 @@
import org.junit.Assert;
suite("test_storage_medium_mtmv","mtmv") {
+ // current, can not support extend storage medium from table
+ return;
// cloud not support set storage medium
if (isCloudMode()) {
return;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
