You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ji...@apache.org on 2022/04/18 10:04:03 UTC
[incubator-doris-manager] 01/01: Revert "[fix] merge #48 (#49)"
This is an automated email from the ASF dual-hosted git repository.
jiafengzheng pushed a commit to branch revert-49-master
in repository https://gitbox.apache.org/repos/asf/incubator-doris-manager.git
commit 8cf8525d334997ff5cafc33d107362c8bc375da1
Author: jiafeng.zhang <zh...@gmail.com>
AuthorDate: Mon Apr 18 18:03:58 2022 +0800
Revert "[fix] merge #48 (#49)"
This reverts commit 6739218d3d3a5bf2404986a82b04a45edc747561.
---
manager/dm-agent/pom.xml | 2 +-
manager/dm-server/pom.xml | 2 +-
.../stack/control/manager/ResourceClusterManager.java | 14 ++++----------
manager/pom.xml | 2 +-
4 files changed, 7 insertions(+), 13 deletions(-)
diff --git a/manager/dm-agent/pom.xml b/manager/dm-agent/pom.xml
index 8923257..f884824 100644
--- a/manager/dm-agent/pom.xml
+++ b/manager/dm-agent/pom.xml
@@ -54,7 +54,7 @@ under the License.
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
- <version>4.5.13</version>
+ <version>4.5</version>
</dependency>
<dependency>
diff --git a/manager/dm-server/pom.xml b/manager/dm-server/pom.xml
index 648e55b..0dc86ab 100644
--- a/manager/dm-server/pom.xml
+++ b/manager/dm-server/pom.xml
@@ -47,7 +47,7 @@ under the License.
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
- <version>2.7</version>
+ <version>2.6</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
diff --git a/manager/dm-server/src/main/java/org/apache/doris/stack/control/manager/ResourceClusterManager.java b/manager/dm-server/src/main/java/org/apache/doris/stack/control/manager/ResourceClusterManager.java
index d7e13c7..75fd80b 100644
--- a/manager/dm-server/src/main/java/org/apache/doris/stack/control/manager/ResourceClusterManager.java
+++ b/manager/dm-server/src/main/java/org/apache/doris/stack/control/manager/ResourceClusterManager.java
@@ -115,6 +115,10 @@ public class ResourceClusterManager {
PMResourceClusterAccessInfo.class);
// TODO:The path can be set separately for each machine later
List<ResourceNodeEntity> nodeEntities = nodeRepository.getByResourceClusterId(resourceClusterId);
+ AgentInstallEventConfigInfo configInfo = new AgentInstallEventConfigInfo();
+ configInfo.setSshUser(accessInfo.getSshUser());
+ configInfo.setSshPort(accessInfo.getSshPort());
+ configInfo.setSshKey(accessInfo.getSshKey());
log.debug("check agent port for resource cluster {} all nodes", resourceClusterId);
@@ -123,11 +127,6 @@ public class ResourceClusterManager {
// but it may expose this problem early if the port has been used.
List<Pair<ResourceNodeEntity, CompletableFuture<Boolean>>> nodeFutures = new ArrayList<>();
for (ResourceNodeEntity nodeEntity : nodeEntities) {
- AgentInstallEventConfigInfo configInfo = new AgentInstallEventConfigInfo();
- configInfo.setSshUser(accessInfo.getSshUser());
- configInfo.setSshPort(accessInfo.getSshPort());
- configInfo.setSshKey(accessInfo.getSshKey());
-
CompletableFuture<Boolean> portCheckFuture = CompletableFuture.supplyAsync(() -> {
try {
nodeAndAgentManager.checkSshConnect(nodeEntity, configInfo);
@@ -170,11 +169,6 @@ public class ResourceClusterManager {
log.debug("install agent for resource cluster {} all nodes", resourceClusterId);
for (ResourceNodeEntity nodeEntity : nodeEntities) {
log.info("start to install agent to {} node {}", nodeEntity.getId(), nodeEntity.getHost());
- AgentInstallEventConfigInfo configInfo = new AgentInstallEventConfigInfo();
- configInfo.setSshUser(accessInfo.getSshUser());
- configInfo.setSshPort(accessInfo.getSshPort());
- configInfo.setSshKey(accessInfo.getSshKey());
-
nodeAndAgentManager.installAgentOperation(nodeEntity, configInfo, requestId);
}
}
diff --git a/manager/pom.xml b/manager/pom.xml
index 813f86f..b5bdbd2 100644
--- a/manager/pom.xml
+++ b/manager/pom.xml
@@ -214,7 +214,7 @@ under the License.
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
- <version>4.13.1</version>
+ <version>4.12</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org