Package com.vmware.bdd.software.mgmt.plugin.model

Examples of com.vmware.bdd.software.mgmt.plugin.model.ClusterBlueprint

1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
   @ResponseBody
   public ValidateResult validateBlueprint(@RequestBody ClusterCreate createSpec) {
      SoftwareManager softwareManager =
            clusterMgr.getClusterConfigMgr().getSoftwareManager(
                  createSpec.getAppManager());
      ClusterBlueprint blueprint = createSpec.toBlueprint();
      ValidateResult result = new ValidateResult();
      boolean validated = false;
      try {
         validated = softwareManager.validateBlueprint(blueprint);
      } catch (ValidationException ve) {
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
   @Test
   public void createClusterTasklet() throws Exception {
      ExternalManagementTask task =
            new ExternalManagementTask("testCluster",
                  ManagementOperation.CREATE, new ClusterBlueprint(),
                  new MockStatusUpdator(),
                  new MockConcurrentClusterEntityManager(),
                  new MockSoftwareManager(), null);

      Map<String, Object> result = task.call();
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
   private ISoftwareManagementTask createExternalTask(String targetName,
         String clusterName) {
      SoftwareManager softwareMgr =
            softwareManagerCollector
                  .getSoftwareManagerByClusterName(clusterName);
      ClusterBlueprint clusterBlueprint =
            lockClusterEntityMgr.getClusterEntityMgr().toClusterBluePrint(
                  clusterName);
      return SoftwareManagementTaskFactory.createExternalMgtTask(targetName,
            ManagementOperation.START_NODES, clusterBlueprint, null,
            lockClusterEntityMgr, softwareMgr, null);
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
         SoftwareManager softMgr, List<BaseNode> toBeDeleted) {
      if (toBeDeleted.isEmpty()) {
         return;
      }

      ClusterBlueprint blueprint =
            clusterEntityMgr.toClusterBluePrint(toBeDeleted.get(0)
                  .getClusterName());
      ClusterReportQueue queue = new ClusterReportQueue();
      List<String> nodeNames = new ArrayList<>();
      for (BaseNode node : toBeDeleted) {
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
         StatusUpdater statusUpdater) {
      ISoftwareManagementTask task;
      SoftwareManager softwareMgr =
            softwareMgrs.getSoftwareManagerByClusterName(clusterName);

      ClusterBlueprint clusterBlueprint =
            getFromJobExecutionContext(chunkContext,
                  JobConstants.CLUSTER_BLUEPRINT_JOB_PARAM,
                  ClusterBlueprint.class);
      if (clusterBlueprint == null) {
         clusterBlueprint =
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
            filterDistroFromAppManager(softwareManager, cluster.getDistro());
      if (cluster.getDistro() == null || stack == null) {
         throw BddException.INVALID_PARAMETER("distro", cluster.getDistro());
      }
      // only check roles validity in server side, but not in CLI and GUI, because roles info exist in server side.
      ClusterBlueprint blueprint = cluster.toBlueprint();
      try {
         softwareManager.validateBlueprint(cluster.toBlueprint());
         cluster.validateClusterCreate(failedMsgList, warningMsgList);
      } catch (ValidationException e) {
         failedMsgList.addAll(e.getFailedMsgList());
View Full Code Here
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
         clusterCreate.setExternalMapReduce(advancedProperties
               .get("ExternalMapReduce"));
         clusterCreate.setLocalRepoURL(advancedProperties.get("LocalRepoURL"));
      }
      // only check roles validity in server side, but not in CLI and GUI, because roles info exist in server side.
      ClusterBlueprint blueprint = clusterCreate.toBlueprint();
      try {
         softwareManager.validateBlueprint(blueprint);
      } catch (ValidationException e) {
         throw ClusterConfigException.INVALID_SPEC(e.getFailedMsgList());
      }
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
                        + cluster.getStatus());
                  logger.debug("Stop sync up for it");
                  ite.remove();
                  continue;
               }
               ClusterBlueprint blueprint =
                     lockedEntityManager.getClusterEntityMgr()
                           .toClusterBluePrint(clusterName);
               SoftwareManager softMgr =
                     softwareManagerCollector
                           .getSoftwareManagerByClusterName(clusterName);
View Full Code Here
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
      update(node);
   }

   public ClusterBlueprint toClusterBluePrint(String clusterName) {
      ClusterEntity clusterEntity = findByName(clusterName);
      ClusterBlueprint blueprint = new ClusterBlueprint();
      Gson gson = new Gson();

      blueprint.setName(clusterEntity.getName());
      blueprint.setInstanceNum(clusterEntity.getRealInstanceNum(true));
      // TODO: topology
      if (clusterEntity.getHadoopConfig() != null) {
         Map<String, Object> clusterConfigs =
               gson.fromJson(clusterEntity.getHadoopConfig(), Map.class);
         blueprint.setConfiguration(clusterConfigs);
      }

      // set HadoopStack
      HadoopStack hadoopStack = new HadoopStack();
      hadoopStack.setDistro(clusterEntity.getDistro());
      hadoopStack.setVendor(clusterEntity.getDistroVendor());
      hadoopStack.setFullVersion(clusterEntity.getDistroVersion());
      blueprint.setHadoopStack(hadoopStack);

      // set nodes/nodegroups
      List<NodeGroupInfo> nodeGroupInfos = new ArrayList<NodeGroupInfo>();
      for (NodeGroupEntity group : clusterEntity.getNodeGroups()) {
         NodeGroupInfo nodeGroupInfo = toNodeGroupInfo(group);
         nodeGroupInfos.add(nodeGroupInfo);
      }
      blueprint.setNodeGroups(nodeGroupInfos);
      return blueprint;
   }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
   }

   @Test
   public void testValidateRoleDependency() {
      ClusterBlueprint blueprint = new ClusterBlueprint();
      List<String> failedMsgList = new ArrayList<String>();
      assertEquals(false, validator.validateRoleDependency(failedMsgList, blueprint));

      NodeGroupInfo compute = new NodeGroupInfo();
      NodeGroupInfo data = new NodeGroupInfo();
      List<NodeGroupInfo> nodeGroupInfos = new ArrayList<NodeGroupInfo>();
      nodeGroupInfos.add(compute);
      nodeGroupInfos.add(data);
      blueprint.setNodeGroups(nodeGroupInfos);
      assertEquals(false, validator.validateRoleDependency(failedMsgList, blueprint));
      assertEquals(2, failedMsgList.size());
      failedMsgList.clear();
      blueprint.setExternalHDFS("hdfs://192.168.0.2:9000");
      compute.setRoles(Arrays.asList(HadoopRole.HADOOP_TASKTRACKER.toString()));
      data.setRoles(Arrays.asList(HadoopRole.HADOOP_DATANODE.toString()));
      assertEquals(false, validator.validateRoleDependency(failedMsgList, blueprint));
      assertEquals(2, failedMsgList.size());
      assertEquals("Duplicate NameNode or DataNode role.", failedMsgList.get(0));
      assertEquals("Missing JobTracker or ResourceManager role.",
            failedMsgList.get(1));
      failedMsgList.clear();
      blueprint.setExternalHDFS("");
      nodeGroupInfos = new ArrayList<NodeGroupInfo>();
      nodeGroupInfos.add(compute);
      blueprint.setNodeGroups(nodeGroupInfos);
      assertEquals(false, validator.validateRoleDependency(failedMsgList, blueprint));
      assertEquals(1, failedMsgList.size());
      assertEquals("Missing role(s): hadoop_jobtracker for service: MAPRED.", failedMsgList.get(0));
      failedMsgList.clear();
      NodeGroupInfo master = new NodeGroupInfo();
      master.setRoles(Arrays.asList(HadoopRole.HADOOP_JOBTRACKER_ROLE
            .toString()));
      nodeGroupInfos = new ArrayList<NodeGroupInfo>();
      nodeGroupInfos.add(master);
      nodeGroupInfos.add(compute);
      blueprint.setNodeGroups(nodeGroupInfos);
      assertEquals(false, validator.validateRoleDependency(failedMsgList, blueprint));
      assertEquals(1, failedMsgList.size());
      assertEquals("Some dependent services " + EnumSet.of(ServiceType.HDFS)
            + " " + ServiceType.MAPRED
            + " relies on cannot be found in the spec file.",
View Full Code Here
TOP

Related Classes of com.vmware.bdd.software.mgmt.plugin.model.ClusterBlueprint

  • com.vmware.bdd.apitypes.ClusterCreate
  • com.vmware.bdd.manager.ClusterConfigManager
  • com.vmware.bdd.manager.ClusterEntityManager
  • com.vmware.bdd.plugin.clouderamgr.service.TestClouderaManagerImpl
  • com.vmware.bdd.plugin.clouderamgr.service.TestCmClusterValidator
  • com.vmware.bdd.rest.RestResource
  • com.vmware.bdd.service.impl.SoftwareSyncupService$StatusSyncUpTask
  • com.vmware.bdd.service.job.ResizeClusterRemoveBadNodeStep
  • com.vmware.bdd.service.job.software.SoftwareManagementStep
  • com.vmware.bdd.service.job.software.TestExternalManagementTask
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.