[doris] branch master updated: [fix](cooldown)add push conf for alter storage policy (#17818)

[pengxiangyu]

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 <diablo...@163.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org