fix style

Author: caiconghui1

fe/fe-core/src/main/java/org/apache/doris/alter/SystemHandler.java

@@ -193,10 +193,11 @@ public static List<Backend> checkDecommission(List<Triple<String, String, Intege
         List<Backend> decommissionBackends = Lists.newArrayList();
         // check if exist
         for (Triple<String, String, Integer> triple : ipHostPortTriples) {
-            Backend backend = infoService.getBackendWithHeartbeatPort(triple.getLeft(), triple.getMiddle(), triple.getRight());
+            Backend backend = infoService.getBackendWithHeartbeatPort(
+                    triple.getLeft(), triple.getMiddle(), triple.getRight());
             if (backend == null) {
-                throw new DdlException("Backend does not exist[" + (triple.getMiddle() == null ? triple.getLeft() : triple.getMiddle())
-                    + ":" + triple.getRight() + "]");
+                throw new DdlException("Backend does not exist[" + (triple.getMiddle() == null ?
+                        triple.getLeft() : triple.getMiddle()) + ":" + triple.getRight() + "]");
             }
             if (backend.isDecommissioned()) {
                 // already under decommission, ignore it
@@ -217,8 +218,8 @@ public synchronized void cancel(CancelStmt stmt) throws DdlException {
         SystemInfoService infoService = Catalog.getCurrentSystemInfo();
         // check if backends is under decommission
         List<Backend> backends = Lists.newArrayList();
-        List<Triple<String, String, Integer>> hostPortTriples = cancelAlterSystemStmt.getIpHostPortTriples();
-        for (Triple<String, String, Integer> triple : hostPortTriples) {
+        List<Triple<String, String, Integer>> ipHostPortTriples = cancelAlterSystemStmt.getIpHostPortTriples();
+        for (Triple<String, String, Integer> triple : ipHostPortTriples) {
             // check if exist
             Backend backend = infoService.getBackendWithHeartbeatPort(triple.getLeft(), triple.getMiddle(), triple.getRight());
             if (backend == null) {
@@ -227,7 +228,6 @@ public synchronized void cancel(CancelStmt stmt) throws DdlException {
             }
 
             if (!backend.isDecommissioned()) {
-                // it's ok. just log
                 LOG.info("backend is not decommissioned[{}]",
                     triple.getMiddle() == null ? triple.getLeft() : triple.getMiddle());
                 continue;

fe/fe-core/src/main/java/org/apache/doris/analysis/AddBackendClause.java

@@ -17,15 +17,13 @@
 
 package org.apache.doris.analysis;
 
-
 import org.apache.doris.common.AnalysisException;
 import org.apache.doris.common.util.PropertyAnalyzer;
 import org.apache.doris.resource.Tag;
 
 import com.google.common.base.Strings;
 import com.google.common.collect.Maps;
 
-
 import java.util.List;
 import java.util.Map;
 

fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java

@@ -1360,7 +1360,6 @@ private void startMasterOnlyDaemonThreads() {
         // start daemon thread to update global partition in memory information periodically
         partitionInMemoryInfoCollector.start();
         streamLoadRecordMgr.start();
-
         getInternalDataSource().getIcebergTableCreationRecordMgr().start();
         if (Config.enable_k8s_detect_container_drift_mode) {
             FQDNManager.start();

fe/fe-core/src/main/java/org/apache/doris/deploy/DeployManager.java

@@ -156,7 +156,7 @@ protected void initEnvVariables(String envElectableFeServiceGroup, String envObs
         this.brokerServiceGroup = Strings.nullToEmpty(System.getenv(envBrokerServiceGroup));
 
         LOG.info("get deploy env: {}, {}, {}, {}", envElectableFeServiceGroup, envObserverFeServiceGroup,
-            envBackendServiceGroup, envBrokerServiceGroup);
+                envBackendServiceGroup, envBrokerServiceGroup);
 
         // electableFeServiceGroup and backendServiceGroup must exist
         if (Strings.isNullOrEmpty(electableFeServiceGroup) || Strings.isNullOrEmpty(backendServiceGroup)) {

fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java

@@ -82,7 +82,7 @@ public K8sDeployManager(Catalog catalog, long intervalMs) {
     protected void initEnvVariables(String envElectableFeServiceGroup, String envObserverFeServiceGroup,
                                     String envBackendServiceGroup, String envBrokerServiceGroup) {
         super.initEnvVariables(envElectableFeServiceGroup, envObserverFeServiceGroup, envBackendServiceGroup,
-            envBrokerServiceGroup);
+                envBrokerServiceGroup);
 
         // namespace
         appNamespace = Strings.nullToEmpty(System.getenv(ENV_APP_NAMESPACE));
@@ -187,9 +187,9 @@ private synchronized KubernetesClient client() {
             if (Config.with_k8s_certs) {
                 // for test only
                 ConfigBuilder configBuilder = new ConfigBuilder().withMasterUrl(TEST_MASTER_URL)
-                    .withTrustCerts(true)
-                    .withCaCertFile(K8S_CA_CERT_FILE).withClientCertFile(K8S_CLIENT_CERT_FILE)
-                    .withClientKeyFile(K8S_CLIENT_KEY_FILE);
+                        .withTrustCerts(true)
+                        .withCaCertFile(K8S_CA_CERT_FILE).withClientCertFile(K8S_CLIENT_CERT_FILE)
+                        .withClientKeyFile(K8S_CLIENT_KEY_FILE);
                 client = new DefaultKubernetesClient(configBuilder.build());
             } else {
                 // When accessing k8s api within the pod, no params need to be provided.

fe/fe-core/src/main/java/org/apache/doris/deploy/impl/LocalFileDeployManager.java

@@ -68,7 +68,7 @@ public LocalFileDeployManager(Catalog catalog, long intervalMs) {
     protected void initEnvVariables(String envElectableFeServiceGroup, String envObserverFeServiceGroup,
                                     String envBackendServiceGroup, String envBrokerServiceGroup) {
         super.initEnvVariables(envElectableFeServiceGroup, envObserverFeServiceGroup, envBackendServiceGroup,
-            envBrokerServiceGroup);
+                envBrokerServiceGroup);
 
         // namespace
         clusterInfoFile = Strings.nullToEmpty(System.getenv(ENV_APP_NAMESPACE));

fe/fe-core/src/main/java/org/apache/doris/metric/PrometheusMetricVisitor.java

@@ -203,7 +203,8 @@ public void getNodeInfo(StringBuilder sb) {
         sb.append(NODE_INFO).append("{type=\"be_node_num\", state=\"decommissioned\"} ")
                 .append(Catalog.getCurrentSystemInfo().getDecommissionedBackendIds().size()).append("\n");
         sb.append(NODE_INFO).append("{type=\"broker_node_num\", state=\"dead\"} ").append(
-                Catalog.getCurrentCatalog().getBrokerMgr().getAllBrokers().stream().filter(b -> !b.isAlive()).count()).append("\n");
+                Catalog.getCurrentCatalog().getBrokerMgr().getAllBrokers().stream().filter(b -> !b.isAlive())
+                        .count()).append("\n");
 
         // only master FE has this metrics, to help the Grafana knows who is the master
         if (Catalog.getCurrentCatalog().isMaster()) {