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

[fix](cooldown)add push conf for alter storage policy (#17818)

Browse Source 
* add push conf for alter storage policy
This commit is contained in:
pengxiangyu
2023-03-16 14:27:27 +08:00
committed by GitHub
parent ee7226348d
commit b3d8be7cac
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -35,6 +35,9 @@ import org.apache.doris.common.io.Writable;
import org.apache.doris.persist.gson.GsonUtils;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ShowResultSet;
import org.apache.doris.task.AgentBatchTask;
import org.apache.doris.task.AgentTaskExecutor;
import org.apache.doris.task.PushStoragePolicyTask;
import com.google.common.base.Joiner;
import com.google.common.base.Strings;
@ -50,6 +53,7 @@ import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
@ -508,6 +512,13 @@ public class PolicyMgr implements Writable {
// log alter
Env.getCurrentEnv().getEditLog().logAlterStoragePolicy(storagePolicy);
AgentBatchTask batchTask = new AgentBatchTask();
for (long backendId : Env.getCurrentSystemInfo().getIdToBackend().keySet()) {
PushStoragePolicyTask pushStoragePolicyTask = new PushStoragePolicyTask(backendId,
Collections.singletonList(storagePolicy), Collections.emptyList(), Collections.emptyList());
batchTask.addTask(pushStoragePolicyTask);
}
AgentTaskExecutor.submit(batchTask);
LOG.info("Alter storage policy success. policy: {}", storagePolicy);
}