diff --git a/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/executor/ComponentCommandExecutor.java b/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/executor/ComponentCommandExecutor.java index 5d9a281c0..ccc46b6cc 100644 --- a/bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/executor/ComponentCommandExecutor.java +++ b/bigtop-manager-agent/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/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/param/BigtopParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/param/BigtopParams.java index 06dd57fa1..c3a229c99 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/param/BigtopParams.java +++ b/bigtop-manager-stack/bigtop-manager-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-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkParams.java index f2698b42d..70db4fada 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/flink/FlinkParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-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 flinkLog4jProperties() { @GlobalParams public Map flinkLog4jCLiProperties() { - Map configurations = LocalSettings.configurations(getServiceName(), "flink-log4j-cli-properties"); + Map configurations = + LocalSettings.configurations(getServiceName(), "flink-log4j-cli-properties"); flinkLog4jCLiPropertiesContent = (String) configurations.get("content"); return configurations; } diff --git a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java index ec96a0773..142d28af3 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-bigtop/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/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopSetup.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopSetup.java index cdf327226..c96b185d6 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopSetup.java +++ b/bigtop-manager-stack/bigtop-manager-stack-bigtop/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-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/kafka/KafkaParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/kafka/KafkaParams.java index c32daf8dc..d1d2ea9ad 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/kafka/KafkaParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-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/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/solr/SolrParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/solr/SolrParams.java index e9513a74d..75613a80a 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/solr/SolrParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-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/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezParams.java index 8c2303c7c..25995737c 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/tez/TezParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-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/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/zookeeper/ZookeeperParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/zookeeper/ZookeeperParams.java index 6a50a392a..c7f82b3b1 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/zookeeper/ZookeeperParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/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/bigtop-manager-stack/bigtop-manager-stack-core/src/main/java/org/apache/bigtop/manager/stack/core/spi/param/BaseParams.java b/bigtop-manager-stack/bigtop-manager-stack-core/src/main/java/org/apache/bigtop/manager/stack/core/spi/param/BaseParams.java index 3bc32f83b..832799018 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-core/src/main/java/org/apache/bigtop/manager/stack/core/spi/param/BaseParams.java +++ b/bigtop-manager-stack/bigtop-manager-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/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/param/InfraParams.java b/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/param/InfraParams.java index 7819cd842..0b7b68c06 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/param/InfraParams.java +++ b/bigtop-manager-stack/bigtop-manager-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/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/v1_0_0/prometheus/PrometheusParams.java b/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/v1_0_0/prometheus/PrometheusParams.java index c23547b82..946eb7d38 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-infra/src/main/java/org/apache/bigtop/manager/stack/infra/v1_0_0/prometheus/PrometheusParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-infra/src/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;