AMBARI-22325 Fix dependency injection in BaseClusterRequest (benyoka)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/7fc437d3 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/7fc437d3 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/7fc437d3 Branch: refs/heads/branch-feature-AMBARI-14714-blueprintv2 Commit: 7fc437d3d689972e458c3ef7f239a7d1ff5d758f Parents: 3cfb74b Author: Balazs Bence Sari <[email protected]> Authored: Mon Nov 13 14:55:16 2017 +0100 Committer: Doroszlai, Attila <[email protected]> Committed: Tue Dec 5 23:55:56 2017 +0100 ---------------------------------------------------------------------- .../org/apache/ambari/server/controller/AmbariServer.java | 2 +- .../server/controller/internal/BaseClusterRequest.java | 9 +++------ .../apache/ambari/server/topology/BlueprintV2Factory.java | 1 + 3 files changed, 5 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/7fc437d3/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java b/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java index 41dc5a6..ed8a17d 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java @@ -936,7 +936,7 @@ public class AmbariServer { HostResourceProvider.setTopologyManager(injector.getInstance(TopologyManager.class)); BlueprintFactory.init(injector.getInstance(BlueprintDAO.class)); BlueprintV2Factory.init(injector.getInstance(BlueprintV2DAO.class)); - BaseClusterRequest.init(injector.getInstance(BlueprintV2Factory.class)); + BaseClusterRequest.init(injector.getInstance(AmbariManagementController.class)); AmbariContext.init(injector.getInstance(HostRoleCommandFactory.class)); PermissionResourceProvider.init(injector.getInstance(PermissionDAO.class)); http://git-wip-us.apache.org/repos/asf/ambari/blob/7fc437d3/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/BaseClusterRequest.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/BaseClusterRequest.java b/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/BaseClusterRequest.java index a38f478..eefb31b 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/BaseClusterRequest.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/controller/internal/BaseClusterRequest.java @@ -27,6 +27,7 @@ import java.util.Set; import org.apache.ambari.server.api.predicate.InvalidQueryException; import org.apache.ambari.server.api.predicate.QueryLexer; import org.apache.ambari.server.api.predicate.Token; +import org.apache.ambari.server.controller.AmbariManagementController; import org.apache.ambari.server.controller.spi.Resource; import org.apache.ambari.server.controller.spi.ResourceProvider; import org.apache.ambari.server.controller.utilities.ClusterControllerHelper; @@ -92,12 +93,8 @@ public abstract class BaseClusterRequest implements TopologyRequest { private static ResourceProvider hostResourceProvider; - /** - * inject blueprint factory - * @param factory blueprint factory - */ - public static void init(BlueprintV2Factory factory) { - blueprintFactory = factory; + public static void init(AmbariManagementController controller) { + blueprintFactory = BlueprintV2Factory.create(controller); } @Override http://git-wip-us.apache.org/repos/asf/ambari/blob/7fc437d3/ambari-server/src/main/java/org/apache/ambari/server/topology/BlueprintV2Factory.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/topology/BlueprintV2Factory.java b/ambari-server/src/main/java/org/apache/ambari/server/topology/BlueprintV2Factory.java index 9870dcb..47aed80 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/topology/BlueprintV2Factory.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/topology/BlueprintV2Factory.java @@ -82,6 +82,7 @@ public class BlueprintV2Factory { protected BlueprintV2Factory() { } + protected BlueprintV2Factory(StackV2Factory stackFactory) { this.stackFactory = stackFactory; }
