codestyle

apache · Dec 7, 2024 · d784f2a · d784f2a
1 parent 8ab2c66
commit d784f2a
Show file tree

Hide file tree

Showing 12 changed files with 20 additions and 20 deletions.
diff --git a/...gent/src/main/java/org/apache/bigtop/manager/agent/executor/ComponentCommandExecutor.java b/...gent/src/main/java/org/apache/bigtop/manager/agent/executor/ComponentCommandExecutor.java
@@ -22,7 +22,6 @@
 import org.apache.bigtop.manager.common.shell.ShellResult;
 import org.apache.bigtop.manager.common.utils.JsonUtils;
 import org.apache.bigtop.manager.grpc.generated.CommandType;
-import org.apache.bigtop.manager.stack.bigtop.v3_3_0.flink.FlinkParams;
 import org.apache.bigtop.manager.stack.core.executor.StackExecutor;
 
 import org.springframework.beans.factory.config.ConfigurableBeanFactory;

diff --git a/...stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/param/BigtopParams.java b/...stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/param/BigtopParams.java
@@ -18,10 +18,11 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.param;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.stack.core.spi.param.BaseParams;
 
+import lombok.NoArgsConstructor;
+
 @NoArgsConstructor
 public abstract class BigtopParams extends BaseParams {
 

diff --git a/...bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkParams.java b/...bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.flink;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -28,6 +27,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;
@@ -98,7 +98,8 @@ public Map<String, Object> flinkLog4jProperties() {
 
     @GlobalParams
     public Map<String, Object> flinkLog4jCLiProperties() {
-        Map<String, Object> configurations = LocalSettings.configurations(getServiceName(), "flink-log4j-cli-properties");
+        Map<String, Object> configurations =
+                LocalSettings.configurations(getServiceName(), "flink-log4j-cli-properties");
         flinkLog4jCLiPropertiesContent = (String) configurations.get("content");
         return configurations;
     }

diff --git a/...gtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java b/...gtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.hadoop;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -30,6 +29,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;

diff --git a/...igtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopSetup.java b/...igtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopSetup.java
@@ -20,7 +20,6 @@
 
 import org.apache.bigtop.manager.common.constants.Constants;
 import org.apache.bigtop.manager.common.shell.ShellResult;
-import org.apache.bigtop.manager.stack.bigtop.utils.HdfsUtil;
 import org.apache.bigtop.manager.stack.core.enums.ConfigType;
 import org.apache.bigtop.manager.stack.core.exception.StackException;
 import org.apache.bigtop.manager.stack.core.spi.param.Params;
@@ -207,13 +206,13 @@ public static ShellResult configure(Params params, String componentName) {
                 hadoopParams.mapredSite(),
                 hadoopParams.getGlobalParamsMap());
 
-//        HdfsUtil.createDirectory(hadoopUser, "/apps");
-//        HdfsUtil.createDirectory(hadoopUser, "/app-logs");
-//        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred");
-//        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/staging");
-//        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history");
-//        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history/tmp");
-//        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history/done");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps");
+        //        HdfsUtil.createDirectory(hadoopUser, "/app-logs");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/staging");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history/tmp");
+        //        HdfsUtil.createDirectory(hadoopUser, "/apps/mapred/history/done");
 
         log.info("Successfully configured Hadoop");
         return ShellResult.success();

diff --git a/...bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/kafka/KafkaParams.java b/...bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/kafka/KafkaParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.kafka;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -28,6 +27,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.util.Map;
 

diff --git a/...k-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/solr/SolrParams.java b/...k-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/solr/SolrParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.solr;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -28,6 +27,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;

diff --git a/...ack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezParams.java b/...ack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.tez;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -30,6 +29,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;

diff --git a/...rc/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/zookeeper/ZookeeperParams.java b/...rc/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/zookeeper/ZookeeperParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.bigtop.v3_3_0.zookeeper;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.utils.Environments;
 import org.apache.bigtop.manager.stack.bigtop.param.BigtopParams;
@@ -28,6 +27,7 @@
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.util.Map;
 

diff --git a/...r-stack-core/src/main/java/org/apache/bigtop/manager/stack/core/spi/param/BaseParams.java b/...r-stack-core/src/main/java/org/apache/bigtop/manager/stack/core/spi/param/BaseParams.java
@@ -18,7 +18,6 @@
  */
 package org.apache.bigtop.manager.stack.core.spi.param;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.enums.Command;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.common.message.entity.pojo.PackageInfo;
@@ -31,6 +30,7 @@
 import org.apache.bigtop.manager.stack.core.utils.LocalSettings;
 
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.lang.reflect.Method;

diff --git a/...er-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/param/InfraParams.java b/...er-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/param/InfraParams.java
@@ -18,10 +18,10 @@
  */
 package org.apache.bigtop.manager.stack.infra.param;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.stack.core.spi.param.BaseParams;
 
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j

diff --git a/...c/main/java/org/apache/bigtop/manager/stack/infra/v1_0_0/prometheus/PrometheusParams.java b/...c/main/java/org/apache/bigtop/manager/stack/infra/v1_0_0/prometheus/PrometheusParams.java
@@ -18,13 +18,13 @@
  */
 package org.apache.bigtop.manager.stack.infra.v1_0_0.prometheus;
 
-import lombok.NoArgsConstructor;
 import org.apache.bigtop.manager.common.message.entity.payload.CommandPayload;
 import org.apache.bigtop.manager.stack.core.spi.param.Params;
 import org.apache.bigtop.manager.stack.infra.param.InfraParams;
 
 import com.google.auto.service.AutoService;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.text.MessageFormat;