This is an automated email from the ASF dual-hosted git repository.

plat1ko 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 c24891069b1 [enhance](Vault) Refresh default storage vault info when 
doing instance check in FE (#36104)
c24891069b1 is described below

commit c24891069b19747167ea445b49879539d43a130b
Author: AlexYue <yj976240...@gmail.com>
AuthorDate: Wed Jun 12 20:57:25 2024 +0800

    [enhance](Vault) Refresh default storage vault info when doing instance 
check in FE (#36104)
---
 .../org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
 
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
index 2fcb5c57cd2..9342c705e9d 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
@@ -17,9 +17,11 @@
 
 package org.apache.doris.cloud.catalog;
 
+import org.apache.doris.catalog.Env;
 import org.apache.doris.cloud.proto.Cloud;
 import org.apache.doris.cloud.system.CloudSystemInfoService;
 import org.apache.doris.common.Config;
+import org.apache.doris.common.Pair;
 import org.apache.doris.common.util.MasterDaemon;
 
 import org.apache.logging.log4j.LogManager;
@@ -47,6 +49,9 @@ public class CloudInstanceStatusChecker extends MasterDaemon {
                         + "cloud_unique_id={}, response={}", 
Config.cloud_unique_id, response);
             } else {
                 
cloudSystemInfoService.setInstanceStatus(response.getInstance().getStatus());
+                
Env.getCurrentEnv().getStorageVaultMgr().setDefaultStorageVault(
+                        
Pair.of(response.getInstance().getDefaultStorageVaultName(),
+                                
response.getInstance().getDefaultStorageVaultId()));
             }
         } catch (Exception e) {
             LOG.warn("get instance from ms exception", e);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to