This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/branch-2.6 by this push:
new 1fcb0e8 AMBARI-22779. Cannot scale cluster if Ambari Server restarted
since blueprint cluster creation
1fcb0e8 is described below
commit 1fcb0e8a804e5f3c78a9e3ed7c06f79e2ea26a1c
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Sun Jan 14 21:02:35 2018 +0100
AMBARI-22779. Cannot scale cluster if Ambari Server restarted since
blueprint cluster creation
---
.../main/java/org/apache/ambari/server/topology/TopologyManager.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/ambari-server/src/main/java/org/apache/ambari/server/topology/TopologyManager.java
b/ambari-server/src/main/java/org/apache/ambari/server/topology/TopologyManager.java
index 074f929..7eb88cf 100644
---
a/ambari-server/src/main/java/org/apache/ambari/server/topology/TopologyManager.java
+++
b/ambari-server/src/main/java/org/apache/ambari/server/topology/TopologyManager.java
@@ -496,6 +496,9 @@ public class TopologyManager {
hostNameCheck(request, topology);
request.setClusterId(clusterId);
+ if (ambariContext.isTopologyResolved(clusterId)) {
+ getOrCreateTopologyTaskExecutor(clusterId).start();
+ }
// this registers/updates all request host groups
topology.update(request);
@@ -971,7 +974,7 @@ public class TopologyManager {
persistedState.registerInTopologyHostInfo(host);
}
- private ExecutorService getOrCreateTopologyTaskExecutor(Long clusterId) {
+ private ManagedThreadPoolExecutor getOrCreateTopologyTaskExecutor(Long
clusterId) {
ManagedThreadPoolExecutor topologyTaskExecutor =
this.topologyTaskExecutorServiceMap.get(clusterId);
if (topologyTaskExecutor == null) {
LOG.info("Creating TopologyTaskExecutorService for clusterId: {}",
clusterId);
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
