|
24 | 24 | import org.apache.doris.catalog.DatabaseIf;
|
25 | 25 | import org.apache.doris.catalog.DistributionInfo;
|
26 | 26 | import org.apache.doris.catalog.DistributionInfo.DistributionInfoType;
|
| 27 | +import org.apache.doris.catalog.DynamicPartitionProperty; |
27 | 28 | import org.apache.doris.catalog.Env;
|
28 | 29 | import org.apache.doris.catalog.HashDistributionInfo;
|
29 | 30 | import org.apache.doris.catalog.MTMV;
|
|
47 | 48 | import org.apache.doris.common.proc.PartitionsProcDir;
|
48 | 49 | import org.apache.doris.common.util.DebugUtil;
|
49 | 50 | import org.apache.doris.common.util.NetUtils;
|
| 51 | +import org.apache.doris.common.util.PropertyAnalyzer; |
50 | 52 | import org.apache.doris.common.util.TimeUtils;
|
51 | 53 | import org.apache.doris.common.util.Util;
|
52 | 54 | import org.apache.doris.datasource.CatalogIf;
|
@@ -1306,6 +1308,17 @@ private static void tablePropertiesForInternalCatalog(UserIdentity currentUserId
|
1306 | 1308 | }
|
1307 | 1309 |
|
1308 | 1310 | Map<String, String> propertiesMap = property.getProperties();
|
| 1311 | + // make [dynamic_partition.]replication_allocation properties same as SHOW CREATE TABLE stmt |
| 1312 | + if (!property.getReplicaAllocation().isNotSet()) { |
| 1313 | + propertiesMap.put(PropertyAnalyzer.PROPERTIES_REPLICATION_ALLOCATION, |
| 1314 | + property.getReplicaAllocation().toCreateStmt()); |
| 1315 | + } |
| 1316 | + DynamicPartitionProperty dynamicProperty = property.getDynamicPartitionProperty(); |
| 1317 | + if (dynamicProperty != null && dynamicProperty.isExist() && !dynamicProperty.getReplicaAllocation() |
| 1318 | + .isNotSet()) { |
| 1319 | + propertiesMap.put(DynamicPartitionProperty.REPLICATION_ALLOCATION, |
| 1320 | + dynamicProperty.getReplicaAllocation().toCreateStmt()); |
| 1321 | + } |
1309 | 1322 | propertiesMap.forEach((key, value) -> {
|
1310 | 1323 | TRow trow = new TRow();
|
1311 | 1324 | trow.addToColumnValue(new TCell().setStringVal(catalog.getName())); // TABLE_CATALOG
|
|
0 commit comments