database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](Cooldown) enhance the policy existence check logic when drop storage policy (#30404)

Browse Source
This commit is contained in:
AlexYue
2024-01-31 22:52:48 +08:00
committed by yiguolei
parent 4f1d76d646
commit 882ba2e1a1
2 changed files with 61 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fe/fe-core/src/main/java/org/apache/doris/policy/PolicyMgr.java
View File

@ -26,6 +26,7 @@ import org.apache.doris.analysis.UserIdentity;
import org.apache.doris.catalog.Database;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.OlapTable;
import org.apache.doris.catalog.PartitionInfo;
import org.apache.doris.catalog.Table;
import org.apache.doris.cluster.ClusterNamespace;
import org.apache.doris.common.AnalysisException;
@ -153,9 +154,14 @@ public class PolicyMgr implements Writable {
List<Table> tables = db.getTables();
for (Table table : tables) {
if (table instanceof OlapTable) {
if (((OlapTable) table).getStoragePolicy().equals(dropPolicyLog.getPolicyName())) {
throw new DdlException("the policy " + dropPolicyLog.getPolicyName() + " is used by table: "
OlapTable olapTable = (OlapTable) table;
PartitionInfo partitionInfo = olapTable.getPartitionInfo();
for (Long partitionId : olapTable.getPartitionIds()) {
String policyName = partitionInfo.getDataProperty(partitionId).getStoragePolicy();
if (policyName.equals(dropPolicyLog.getPolicyName())) {
throw new DdlException("the policy " + policyName + " is used by table: "
+ table.getName());
}
}
}
}