This is an automated email from the ASF dual-hosted git repository.
pengxiangyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b3d8be7cac [fix](cooldown)add push conf for alter storage policy
(#17818)
b3d8be7cac is described below
commit b3d8be7cac8b8a467bd365568edcc9d3fd6444d4
Author: pengxiangyu <[email protected]>
AuthorDate: Thu Mar 16 14:27:27 2023 +0800
[fix](cooldown)add push conf for alter storage policy (#17818)
* add push conf for alter storage policy
---
.../src/main/java/org/apache/doris/policy/PolicyMgr.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/policy/PolicyMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/policy/PolicyMgr.java
index 7965131874..ce47793ffe 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/policy/PolicyMgr.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/policy/PolicyMgr.java
@@ -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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
