| /** |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| var App = require('app'); |
| var stringUtils = require('utils/string_utils'); |
| |
| App.WizardStep8Controller = Em.Controller.extend({ |
| name: 'wizardStep8Controller', |
| rawContent: require('data/review_configs'), |
| totalHosts: [], |
| clusterInfo: [], |
| services: [], |
| configs: [], |
| globals: [], |
| ajaxQueue: [], |
| configMapping: function(){ |
| return App.config.get('configMapping').all(true); |
| }.property('App.config.configMapping'), |
| |
| slaveComponentConfig: null, |
| isSubmitDisabled: false, |
| isBackBtnDisabled: false, |
| hasErrorOccurred: false, |
| servicesInstalled: false, |
| serviceConfigTags: [], |
| securityEnabled: false, |
| /** |
| * During page save time, we set the host overrides to the server. |
| * The new host -> site:tag map is stored below. This will be |
| * useful during save, to update the host's host components. Also, |
| * it will be useful in deletion of overrides. |
| * |
| * Example: |
| * { |
| * 'hostname1': { |
| * 'global': { |
| * 'tagName': 'tag3187261938_hostname1', |
| * 'map': { |
| * 'hadoop_heapsize': '2048m' |
| * } |
| * } |
| * } |
| * } |
| * |
| * @see loadedHostToOverrideSiteToTagMap |
| */ |
| savedHostToOverrideSiteToTagMap: {}, |
| selectedConfigGroup: null, |
| configGroups: [], |
| |
| selectedServices: function () { |
| return this.get('content.services').filterProperty('isSelected', true).filterProperty('isInstalled', false); |
| }.property('content.services').cacheable(), |
| |
| clearStep: function () { |
| this.get('services').clear(); |
| this.get('configs').clear(); |
| this.get('globals').clear(); |
| this.get('clusterInfo').clear(); |
| this.get('serviceConfigTags').clear(); |
| this.set('servicesInstalled', false); |
| }, |
| |
| loadStep: function () { |
| console.log("TRACE: Loading step8: Review Page"); |
| if (this.get('content.controllerName') != 'installerController') { |
| this.set('securityEnabled', App.router.get('mainAdminSecurityController').getUpdatedSecurityStatus()); |
| } |
| this.clearStep(); |
| this.formatProperties(); |
| this.loadGlobals(); |
| this.loadConfigs(); |
| this.loadClusterInfo(); |
| this.loadServices(); |
| this.set('isSubmitDisabled', false); |
| this.set('isBackBtnDisabled', false); |
| }, |
| /** |
| * replace whitespace character with coma between directories |
| */ |
| formatProperties: function(){ |
| this.get('content.serviceConfigProperties').forEach(function(_configProperty){ |
| _configProperty.value = App.config.trimProperty(_configProperty,false); |
| }); |
| }, |
| |
| loadGlobals: function () { |
| var globals = this.get('content.serviceConfigProperties').filterProperty('id', 'puppet var'); |
| if (globals.someProperty('name', 'hive_database')) { |
| var hiveDb = globals.findProperty('name', 'hive_database'); |
| var hiveDbType = {name: 'hive_database_type', value: 'mysql'}; |
| var hiveJdbcDriver = {name: 'hive_jdbc_driver'}; |
| |
| if (hiveDb.value === 'New MySQL Database') { |
| if (globals.someProperty('name', 'hive_ambari_host')) { |
| globals.findProperty('name', 'hive_hostname').value = globals.findProperty('name', 'hive_ambari_host').value; |
| hiveDbType.value = 'mysql'; |
| hiveJdbcDriver.value = 'com.mysql.jdbc.Driver'; |
| } |
| globals = globals.without(globals.findProperty('name', 'hive_existing_mysql_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_mysql_database')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_oracle_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_oracle_database')); |
| } else if (hiveDb.value === 'Existing MySQL Database'){ |
| globals.findProperty('name', 'hive_hostname').value = globals.findProperty('name', 'hive_existing_mysql_host').value; |
| hiveDbType.value = 'mysql'; |
| hiveJdbcDriver.value = 'com.mysql.jdbc.Driver'; |
| globals = globals.without(globals.findProperty('name', 'hive_ambari_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_ambari_database')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_oracle_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_oracle_database')); |
| } else { //existing oracle database |
| globals.findProperty('name', 'hive_hostname').value = globals.findProperty('name', 'hive_existing_oracle_host').value; |
| hiveDbType.value = 'oracle'; |
| hiveJdbcDriver.value = 'oracle.jdbc.driver.OracleDriver'; |
| globals = globals.without(globals.findProperty('name', 'hive_ambari_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_ambari_database')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_mysql_host')); |
| globals = globals.without(globals.findProperty('name', 'hive_existing_mysql_database')); |
| } |
| globals.push(hiveDbType); |
| globals.push(hiveJdbcDriver); |
| } |
| |
| if (globals.someProperty('name', 'oozie_database')) { |
| var oozieDb = globals.findProperty('name', 'oozie_database'); |
| var oozieDbType = {name:'oozie_database_type'}; |
| var oozieJdbcDriver = {name: 'oozie_jdbc_driver'}; |
| |
| if (oozieDb.value === 'New Derby Database') { |
| globals.findProperty('name', 'oozie_hostname').value = globals.findProperty('name', 'oozie_ambari_host').value; |
| oozieDbType.value = 'derby'; |
| oozieJdbcDriver.value = 'org.apache.derby.jdbc.EmbeddedDriver'; |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_mysql_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_mysql_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_oracle_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_oracle_database')); |
| } else if (oozieDb.value === 'Existing MySQL Database') { |
| globals.findProperty('name', 'oozie_hostname').value = globals.findProperty('name', 'oozie_existing_mysql_host').value; |
| oozieDbType.value = 'mysql'; |
| oozieJdbcDriver.value = 'com.mysql.jdbc.Driver'; |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_oracle_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_oracle_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_derby_database')); |
| } else { // existing oracle database |
| globals.findProperty('name', 'oozie_hostname').value = globals.findProperty('name', 'oozie_existing_oracle_host').value; |
| oozieDbType.value = 'oracle'; |
| oozieJdbcDriver.value = 'oracle.jdbc.driver.OracleDriver'; |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_ambari_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_mysql_host')); |
| globals = globals.without(globals.findProperty('name', 'oozie_existing_mysql_database')); |
| globals = globals.without(globals.findProperty('name', 'oozie_derby_database')); |
| } |
| globals.push(oozieDbType); |
| globals.push(oozieJdbcDriver); |
| } |
| |
| this.set('globals', globals); |
| }, |
| |
| loadConfigs: function () { |
| //storedConfigs contains custom configs as well |
| var serviceConfigProperties = this.get('content.serviceConfigProperties').filterProperty('id', 'site property'); |
| serviceConfigProperties.forEach(function(_config){ |
| _config.value = (typeof _config.value === "boolean") ? _config.value.toString() : _config.value; |
| }); |
| var storedConfigs = serviceConfigProperties.filterProperty('value'); |
| var uiConfigs = this.loadUiSideConfigs(); |
| this.set('configs', storedConfigs.concat(uiConfigs)); |
| }, |
| |
| loadUiSideConfigs: function () { |
| var uiConfig = []; |
| var configs = this.get('configMapping').filterProperty('foreignKey', null); |
| this.addDynamicProperties(configs); |
| configs.forEach(function (_config) { |
| var valueWithOverrides = this.getGlobConfigValueWithOverrides(_config.templateName, _config.value, _config.name); |
| uiConfig.pushObject({ |
| "id": "site property", |
| "name": _config.name, |
| "value": valueWithOverrides.value, |
| "filename": _config.filename, |
| "overrides": valueWithOverrides.overrides |
| }); |
| }, this); |
| var dependentConfig = $.extend(true, [], this.get('configMapping').filterProperty('foreignKey')); |
| dependentConfig.forEach(function (_config) { |
| App.config.setConfigValue(uiConfig, this.get('content.serviceConfigProperties'), _config, this.get('globals')); |
| uiConfig.pushObject({ |
| "id": "site property", |
| "name": _config._name || _config.name, |
| "value": _config.value, |
| "filename": _config.filename |
| }); |
| }, this); |
| return uiConfig; |
| }, |
| |
| addDynamicProperties: function(configs) { |
| var templetonHiveProperty = this.get('content.serviceConfigProperties').someProperty('name', 'templeton.hive.properties'); |
| if (!templetonHiveProperty) { |
| configs.pushObject({ |
| "name": "templeton.hive.properties", |
| "templateName": ["hivemetastore_host"], |
| "foreignKey": null, |
| "value": "hive.metastore.local=false,hive.metastore.uris=thrift://<templateName[0]>:9083,hive.metastore.sasl.enabled=yes,hive.metastore.execute.setugi=true,hive.metastore.warehouse.dir=/apps/hive/warehouse", |
| "filename": "webhcat-site.xml" |
| }); |
| } |
| }, |
| |
| getRegisteredHosts: function () { |
| var allHosts = this.get('content.hosts'); |
| var hosts = []; |
| for (var hostName in allHosts) { |
| if (allHosts[hostName].bootStatus == 'REGISTERED') { |
| allHosts[hostName].hostName = allHosts[hostName].name; |
| hosts.pushObject(allHosts[hostName]); |
| } |
| } |
| return hosts; |
| }, |
| |
| /** |
| * Set all site property that are derived from other puppet-variable |
| * @return { |
| * value: '...', |
| * overrides: { |
| * 'value1': [h1, h2], |
| * 'value2': [h3] |
| * } |
| * } |
| */ |
| |
| getGlobConfigValueWithOverrides: function (templateName, expression, name) { |
| var express = expression.match(/<(.*?)>/g); |
| var value = expression; |
| if (express == null) { |
| return { value : expression, overrides: []}; // if site property do not map any global property then return the value |
| } |
| var overrideHostToValue = {}; |
| express.forEach(function (_express) { |
| //console.log("The value of template is: " + _express); |
| var index = parseInt(_express.match(/\[([\d]*)(?=\])/)[1]); |
| if (this.get('globals').someProperty('name', templateName[index])) { |
| //console.log("The name of the variable is: " + this.get('content.serviceConfigProperties').findProperty('name', templateName[index]).name); |
| var globalObj = this.get('globals').findProperty('name', templateName[index]); |
| var globValue = globalObj.value; |
| // Hack for templeton.zookeeper.hosts |
| var preReplaceValue = null; |
| if (value !== null) { // if the property depends on more than one template name like <templateName[0]>/<templateName[1]> then don't proceed to the next if the prior is null or not found in the global configs |
| preReplaceValue = value; |
| value = this._replaceConfigValues(name, _express, value, globValue); |
| } |
| if(globalObj.overrides!=null){ |
| globalObj.overrides.forEach(function(override){ |
| var ov = override.value; |
| var hostsArray = override.hosts; |
| hostsArray.forEach(function(host){ |
| if(!(host in overrideHostToValue)){ |
| overrideHostToValue[host] = this._replaceConfigValues(name, _express, preReplaceValue, ov); |
| }else{ |
| overrideHostToValue[host] = this._replaceConfigValues(name, _express, overrideHostToValue[host], ov); |
| } |
| }, this); |
| }, this); |
| } |
| } else { |
| /* |
| console.log("ERROR: The variable name is: " + templateName[index]); |
| console.log("ERROR: mapped config from configMapping file has no corresponding variable in " + |
| "content.serviceConfigProperties. Two possible reasons for the error could be: 1) The service is not selected. " + |
| "and/OR 2) The service_config metadata file has no corresponding global var for the site property variable"); |
| */ |
| value = null; |
| } |
| }, this); |
| |
| var valueWithOverrides = { |
| value: value, |
| overrides: [] |
| }; |
| var overrideValueToHostMap = {}; |
| if(!jQuery.isEmptyObject(overrideHostToValue)){ |
| for(var host in overrideHostToValue){ |
| var hostVal = overrideHostToValue[host]; |
| if(!(hostVal in overrideValueToHostMap)){ |
| overrideValueToHostMap[hostVal] = []; |
| } |
| overrideValueToHostMap[hostVal].push(host); |
| } |
| } |
| for(var val in overrideValueToHostMap){ |
| valueWithOverrides.overrides.push({ |
| value: val, |
| hosts: overrideValueToHostMap[val] |
| }); |
| } |
| return valueWithOverrides; |
| }, |
| |
| _replaceConfigValues: function (name, express, value, globValue) { |
| if (name === "templeton.zookeeper.hosts" || name === 'hbase.zookeeper.quorum') { |
| // globValue is an array of ZooKeeper Server hosts |
| var zooKeeperPort = '2181'; |
| if (name === "templeton.zookeeper.hosts") { |
| var zooKeeperServers = globValue.map(function (item) { |
| return item + ':' + zooKeeperPort; |
| }).join(','); |
| value = value.replace(express, zooKeeperServers); |
| } else { |
| value = value.replace(express, globValue.join(',')); |
| } |
| } else { |
| value = value.replace(express, globValue); |
| } |
| return value; |
| }, |
| |
| /** |
| * Load all info about cluster to <code>clusterInfo</code> variable |
| */ |
| loadClusterInfo: function () { |
| |
| //Admin name |
| var admin = this.rawContent.findProperty('config_name', 'Admin'); |
| admin.config_value = App.db.getLoginName(); |
| console.log("STEP8: the value of content cluster name: " + App.db.getLoginName()); |
| if (admin.config_value) { |
| this.get('clusterInfo').pushObject(Ember.Object.create(admin)); |
| } |
| |
| // cluster name |
| var cluster = this.rawContent.findProperty('config_name', 'cluster'); |
| cluster.config_value = this.get('content.cluster.name'); |
| console.log("STEP8: the value of content cluster name: " + this.get('content.cluster.name')); |
| this.get('clusterInfo').pushObject(Ember.Object.create(cluster)); |
| |
| //hosts |
| var masterHosts = this.get('content.masterComponentHosts').mapProperty('hostName').uniq(); |
| var slaveHosts = this.get('content.slaveComponentHosts'); |
| |
| var hostObj = []; |
| slaveHosts.forEach(function (_hosts) { |
| hostObj = hostObj.concat(_hosts.hosts); |
| }, this); |
| |
| slaveHosts = hostObj.mapProperty('hostName').uniq(); |
| |
| var componentHosts = masterHosts.concat(slaveHosts).uniq(); |
| var totalHosts = App.Host.find().mapProperty('hostName').concat(componentHosts).uniq(); |
| var newHostsCount = totalHosts.length - App.Host.find().content.length; |
| this.set('totalHosts', totalHosts); |
| var totalHostsObj = this.rawContent.findProperty('config_name', 'hosts'); |
| totalHostsObj.config_value = totalHosts.length + ' (' + newHostsCount + ' new)'; |
| this.get('clusterInfo').pushObject(Ember.Object.create(totalHostsObj)); |
| |
| //repo |
| var repoOption = this.get('content.installOptions.localRepo'); |
| var repoObj = this.rawContent.findProperty('config_name', 'Repo'); |
| if (repoOption) { |
| repoObj.config_value = 'Yes'; |
| } else { |
| repoObj.config_value = 'No'; |
| } |
| this.get('clusterInfo').pushObject(Ember.Object.create(repoObj)); |
| }, |
| |
| |
| /** |
| * Load all info about services to <code>services</code> variable |
| */ |
| loadServices: function () { |
| var selectedServices = this.get('selectedServices'); |
| this.set('services', selectedServices.mapProperty('serviceName')); |
| |
| selectedServices.forEach(function (_service) { |
| console.log('INFO: step8: Name of the service from getService function: ' + _service.serviceName); |
| var reviewService = this.rawContent.findProperty('config_name', 'services'); |
| var serviceObj = reviewService.config_value.findProperty('service_name', _service.serviceName); |
| |
| if (serviceObj) { |
| switch (serviceObj.service_name) { |
| case 'HDFS': |
| this.loadHDFS(serviceObj); |
| break; |
| case 'HCFS': |
| this.loadHCFS(serviceObj); |
| break; |
| case 'MAPREDUCE': |
| this.loadMapReduce(serviceObj); |
| break; |
| case 'MAPREDUCE2': |
| this.loadMapReduce2(serviceObj); |
| break; |
| case 'YARN': |
| this.loadYARN(serviceObj); |
| break; |
| case 'HIVE': |
| this.loadHive(serviceObj); |
| break; |
| case 'HBASE': |
| this.loadHbase(serviceObj); |
| break; |
| case 'ZOOKEEPER': |
| this.loadZk(serviceObj); |
| break; |
| case 'OOZIE': |
| this.loadOozie(serviceObj); |
| break; |
| case 'NAGIOS': |
| this.loadNagios(serviceObj); |
| break; |
| case 'GANGLIA': |
| this.loadGanglia(serviceObj); |
| break; |
| case 'HUE': |
| this.loadHue(serviceObj); |
| break; |
| /* case 'TEZ': |
| break; |
| case 'PIG': |
| this.loadPig(serviceObj); |
| break; |
| case 'SQOOP': |
| this.loadSqoop(serviceObj); |
| break; |
| */ |
| case 'HCATALOG': |
| break; |
| default: |
| } |
| } |
| }, this); |
| }, |
| |
| /** |
| * load all info about HDFS service |
| * @param hdfsObj |
| */ |
| loadHDFS: function (hdfsObj) { |
| hdfsObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'NameNode': |
| this.loadNnValue(_component); |
| break; |
| case 'SecondaryNameNode': |
| this.loadSnnValue(_component); |
| break; |
| case 'DataNodes': |
| this.loadDnValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| //var |
| this.get('services').pushObject(hdfsObj); |
| }, |
| |
| /** |
| * load all info about HCFS service |
| * @param hcfsObj |
| */ |
| loadHCFS: function (hcfsObj) { |
| hcfsObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'HCFS Client': |
| this.loadHCFSClientValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(hcfsObj); |
| }, |
| |
| loadHCFSClientValue: function (hcfsComponent) { |
| var hcfsClientHosts = this.get('content.slaveComponentHosts').findProperty('displayName', 'Client'); |
| var totalHCFSHosts = hcfsClientHosts.hosts.length; |
| hcfsComponent.set('component_value', totalHCFSHosts + ' hosts'); |
| }, |
| |
| loadNnValue: function (nnComponent) { |
| var nnHostName = this.get('content.masterComponentHosts').findProperty('display_name', nnComponent.display_name); |
| nnComponent.set('component_value', nnHostName.hostName); |
| }, |
| |
| loadSnnValue: function (snnComponent) { |
| var snnHostName = this.get('content.masterComponentHosts').findProperty('display_name', 'SNameNode'); |
| snnComponent.set('component_value', snnHostName.hostName); |
| }, |
| |
| loadDnValue: function (dnComponent) { |
| var dnHosts = this.get('content.slaveComponentHosts').findProperty('displayName', 'DataNode'); |
| var totalDnHosts = dnHosts.hosts.length; |
| /* var totalGroups = this.get('slaveComponentConfig.components').findProperty('componentName', 'DATANODE').groups.length; |
| var groupLabel; |
| if (totalGroups == 1) { |
| groupLabel = 'group'; |
| } else { |
| groupLabel = 'groups'; |
| } |
| */ |
| dnComponent.set('component_value', totalDnHosts + Em.I18n.t('installer.step8.hosts')); |
| }, |
| |
| |
| /** |
| * Load all info about mapReduce service |
| * @param mrObj |
| */ |
| loadMapReduce: function (mrObj) { |
| mrObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'JobTracker': |
| this.loadJtValue(_component); |
| break; |
| case 'TaskTrackers': |
| this.loadTtValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(mrObj); |
| }, |
| |
| loadMapReduce2: function(mrObj){ |
| mrObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'History Server': |
| _component.set('component_value', this.get('content.masterComponentHosts').findProperty('component', 'HISTORYSERVER').hostName); |
| break; |
| } |
| }, this); |
| this.get('services').pushObject(mrObj); |
| }, |
| |
| loadYARN: function(mrObj){ |
| mrObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'NodeManager': |
| this.loadNMValue(_component); |
| break; |
| case 'ResourceManager': |
| _component.set('component_value', this.get('content.masterComponentHosts').findProperty('component', 'RESOURCEMANAGER').hostName); |
| break; |
| case 'History Server': |
| _component.set('component_value', this.get('content.masterComponentHosts').findProperty('component', 'HISTORYSERVER').hostName); |
| break; |
| } |
| }, this); |
| this.get('services').pushObject(mrObj); |
| }, |
| |
| loadNMValue: function (nmComponent) { |
| var nmHosts = this.get('content.slaveComponentHosts').findProperty('componentName', 'NODEMANAGER'); |
| nmComponent.set('component_value', nmHosts.hosts.length + Em.I18n.t('installer.step8.hosts')); |
| }, |
| |
| loadJtValue: function (jtComponent) { |
| var jtHostName = this.get('content.masterComponentHosts').findProperty('display_name', jtComponent.display_name); |
| jtComponent.set('component_value', jtHostName.hostName); |
| }, |
| |
| loadTtValue: function (ttComponent) { |
| var ttHosts = this.get('content.slaveComponentHosts').findProperty('displayName', 'TaskTracker'); |
| var totalTtHosts = ttHosts.hosts.length; |
| ttComponent.set('component_value', totalTtHosts + Em.I18n.t('installer.step8.hosts')); |
| }, |
| |
| /** |
| * Load all info about Hive service |
| * @param hiveObj |
| */ |
| loadHive: function (hiveObj) { |
| hiveObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'Hive Metastore': |
| this.loadHiveMetaStoreValue(_component); |
| break; |
| case 'Database': |
| this.loadHiveDbValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(hiveObj); |
| |
| }, |
| |
| loadHiveMetaStoreValue: function (metaStoreComponent) { |
| var hiveHostName = this.get('content.masterComponentHosts').findProperty('display_name', 'HiveServer2'); |
| metaStoreComponent.set('component_value', hiveHostName.hostName); |
| }, |
| |
| loadHiveDbValue: function (dbComponent) { |
| var hiveDb = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'hive_database'); |
| if (hiveDb.value === 'New MySQL Database') { |
| dbComponent.set('component_value', 'MySQL (New Database)'); |
| } else if(hiveDb.value === 'Existing MySQL Database'){ |
| var db = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'hive_existing_mysql_database'); |
| dbComponent.set('component_value', db.value + ' (' + hiveDb.value + ')'); |
| } else { // existing oracle database |
| var db = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'hive_existing_oracle_database'); |
| dbComponent.set('component_value', db.value + ' (' + hiveDb.value + ')'); |
| } |
| }, |
| |
| /** |
| * Load all info about Hbase |
| * @param hbaseObj |
| */ |
| loadHbase: function (hbaseObj) { |
| hbaseObj.service_components.forEach(function (_component) { |
| switch (_component.display_name) { |
| case 'Master': |
| this.loadMasterValue(_component); |
| break; |
| case 'RegionServers': |
| this.loadRegionServerValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(hbaseObj); |
| }, |
| |
| loadMasterValue: function (hbaseMaster) { |
| var hbaseHostName = this.get('content.masterComponentHosts').filterProperty('display_name', 'HBase Master'); |
| if (hbaseHostName.length == 1) { |
| hbaseMaster.set('component_value', hbaseHostName[0].hostName); |
| } else { |
| hbaseMaster.set('component_value', hbaseHostName[0].hostName + Em.I18n.t('installer.step8.other').format(hbaseHostName.length - 1)); |
| } |
| }, |
| |
| loadRegionServerValue: function (rsComponent) { |
| var rsHosts = this.get('content.slaveComponentHosts').findProperty('displayName', 'RegionServer'); |
| var totalRsHosts = rsHosts.hosts.length; |
| /* var totalGroups = this.get('slaveComponentConfig.components').findProperty('componentName', 'HBASE_REGIONSERVER').groups.length; |
| var groupLabel; |
| if (totalGroups == 1) { |
| groupLabel = 'group'; |
| } else { |
| groupLabel = 'groups'; |
| } */ |
| rsComponent.set('component_value', totalRsHosts + Em.I18n.t('installer.step8.hosts')); |
| }, |
| |
| /** |
| * Load all info about ZooKeeper service |
| * @param zkObj |
| */ |
| loadZk: function (zkObj) { |
| zkObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'Servers': |
| this.loadZkServerValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(zkObj); |
| }, |
| |
| loadZkServerValue: function (serverComponent) { |
| var zkHostNames = this.get('content.masterComponentHosts').filterProperty('display_name', 'ZooKeeper').length; |
| var hostSuffix; |
| if (zkHostNames === 1) { |
| hostSuffix = Em.I18n.t('installer.step8.host'); |
| } else { |
| hostSuffix = Em.I18n.t('installer.step8.hosts'); |
| } |
| serverComponent.set('component_value', zkHostNames + ' ' + hostSuffix); |
| }, |
| |
| /** |
| * Load all info about Hue services |
| * @param hueObj |
| */ |
| loadHue: function (hueObj) { |
| hueObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'Server': |
| this.loadHueServerValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(hueObj); |
| }, |
| |
| loadHueServerValue: function (hueServer) { |
| var hueServerName = this.get('content.masterComponentHosts').findProperty('display_name', 'Hue Server'); |
| hueServer.set('component_value', hueServerName.hostName); |
| }, |
| |
| /** |
| * Load all info about Oozie services |
| * @param oozieObj |
| */ |
| loadOozie: function (oozieObj) { |
| oozieObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'Server': |
| this.loadOozieServerValue(_component); |
| break; |
| case 'Database': |
| // TODO: uncomment when ready to integrate with Oozie Database other than Derby |
| this.loadOozieDbValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(oozieObj); |
| }, |
| |
| loadOozieServerValue: function (oozieServer) { |
| var oozieServerName = this.get('content.masterComponentHosts').findProperty('display_name', 'Oozie Server'); |
| oozieServer.set('component_value', oozieServerName.hostName); |
| }, |
| |
| loadOozieDbValue: function (dbComponent) { |
| var oozieDb = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'oozie_database'); |
| if (oozieDb.value === 'New Derby Database'){ |
| var db = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'oozie_derby_database'); |
| dbComponent.set('component_value', db.value + ' (' + oozieDb.value + ')'); |
| }/* else if (oozieDb.value === 'New MySQL Database') { |
| dbComponent.set('component_value', 'MySQL (New Database)'); |
| } */else if(oozieDb.value === 'Existing MySQL Database'){ |
| var db = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'oozie_existing_mysql_database'); |
| dbComponent.set('component_value', db.value + ' (' + oozieDb.value + ')'); |
| } else { // existing oracle database |
| var db = this.get('wizardController').getDBProperty('serviceConfigProperties').findProperty('name', 'oozie_existing_oracle_database'); |
| dbComponent.set('component_value', db.value + ' (' + oozieDb.value + ')'); |
| } |
| |
| }, |
| |
| |
| /** |
| * Load all info about Nagios service |
| * @param nagiosObj |
| */ |
| loadNagios: function (nagiosObj) { |
| nagiosObj.service_components.forEach(function (_component) { |
| switch (_component.display_name) { |
| case 'Server': |
| this.loadNagiosServerValue(_component); |
| break; |
| case 'Administrator': |
| this.loadNagiosAdminValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(nagiosObj); |
| }, |
| |
| loadNagiosServerValue: function (nagiosServer) { |
| var nagiosServerName = this.get('content.masterComponentHosts').findProperty('display_name', 'Nagios Server'); |
| nagiosServer.set('component_value', nagiosServerName.hostName); |
| }, |
| |
| loadNagiosAdminValue: function (nagiosAdmin) { |
| var config = this.get('content.serviceConfigProperties'); |
| var adminLoginName = config.findProperty('name', 'nagios_web_login'); |
| var adminEmail = config.findProperty('name', 'nagios_contact'); |
| nagiosAdmin.set('component_value', adminLoginName.value + ' / (' + adminEmail.value + ')'); |
| }, |
| |
| /** |
| * Load all info about ganglia |
| * @param gangliaObj |
| */ |
| loadGanglia: function (gangliaObj) { |
| gangliaObj.get('service_components').forEach(function (_component) { |
| switch (_component.get('display_name')) { |
| case 'Server': |
| this.loadGangliaServerValue(_component); |
| break; |
| default: |
| } |
| }, this); |
| this.get('services').pushObject(gangliaObj); |
| }, |
| |
| loadGangliaServerValue: function (gangliaServer) { |
| var gangliaServerName = this.get('content.masterComponentHosts').findProperty('display_name', 'Ganglia Server'); |
| gangliaServer.set('component_value', gangliaServerName.hostName); |
| }, |
| |
| loadSqoop: function (sqoopObj) { |
| this.get('services').pushObject(sqoopObj); |
| }, |
| |
| loadPig: function (pigObj) { |
| this.get('services').pushObject(pigObj); |
| }, |
| |
| /** |
| * Onclick handler for <code>next</code> button |
| */ |
| submit: function () { |
| if (this.get('isSubmitDisabled')) { |
| return; |
| } |
| if ((this.get('content.controllerName') == 'addHostController') && this.get('securityEnabled')) { |
| var self = this; |
| App.showConfirmationPopup(function() { |
| self.submitProceed(); |
| }, Em.I18n.t('installer.step8.securityConfirmationPopupBody')); |
| } |
| else { |
| this.submitProceed(); |
| } |
| }, |
| |
| submitProceed: function() { |
| this.set('isSubmitDisabled', true); |
| this.set('isBackBtnDisabled', true); |
| if (this.get('content.controllerName') == 'addHostController') { |
| App.router.get('addHostController').setLowerStepsDisable(4); |
| } |
| |
| // checkpoint the cluster status on the server so that the user can resume from where they left off |
| switch (this.get('content.controllerName')) { |
| case 'installerController': |
| App.clusterStatus.setClusterStatus({ |
| clusterName: this.get('clusterName'), |
| clusterState: 'CLUSTER_DEPLOY_PREP_2', |
| wizardControllerName: this.get('content.controllerName'), |
| localdb: App.db.data |
| }); |
| break; |
| case 'addHostController': |
| App.clusterStatus.setClusterStatus({ |
| clusterName: this.get('clusterName'), |
| clusterState: 'ADD_HOSTS_DEPLOY_PREP_2', |
| wizardControllerName: this.get('content.controllerName'), |
| localdb: App.db.data |
| }); |
| break; |
| case 'addServiceController': |
| App.clusterStatus.setClusterStatus({ |
| clusterName: this.get('clusterName'), |
| clusterState: 'ADD_SERVICES_DEPLOY_PREP_2', |
| wizardControllerName: this.get('content.controllerName'), |
| localdb: App.db.data |
| }); |
| break; |
| default: |
| break; |
| } |
| // delete any existing clusters to start from a clean slate |
| // before creating a new cluster in install wizard |
| // TODO: modify for multi-cluster support |
| if (this.get('content.controllerName') == 'installerController' && (!App.testMode)) { |
| var clusterNames = this.getExistingClusterNames(); |
| this.deleteClusters(clusterNames); |
| } |
| this.setLocalRepositories(); |
| this.createCluster(); |
| this.createSelectedServices(); |
| this.createConfigurations(); |
| this.createComponents(); |
| this.registerHostsToCluster(); |
| this.createAllHostComponents(); |
| this.createHostOverrideConfigurations(); |
| |
| this.ajaxQueueFinished = function () { |
| console.log('everything is loaded'); |
| App.router.send('next'); |
| }; |
| this.doNextAjaxCall(); |
| }, |
| |
| /** |
| * Used in progress bar |
| */ |
| ajaxQueueLength: function () { |
| return this.get('ajaxQueue').length; |
| }.property('ajaxQueue.length'), |
| |
| /** |
| * Used in progress bar |
| */ |
| ajaxQueueLeft: 0, |
| |
| setAmbariUIDb: function () { |
| var dbContent = this.get('content.slaveGroupProperties'); |
| var slaveComponentConfig = this.get("slaveComponentConfig"); |
| this.persistKeyValues(slaveComponentConfig.version, dbContent); |
| this.persistKeyValues('current_version', slaveComponentConfig.version); |
| }, |
| |
| persistKeyValues: function (key, value) { |
| |
| var str = "{ '" + key + "' : '" + JSON.stringify(value) + "'}"; |
| var obj = eval("(" + str + ")"); |
| |
| this.ajax({ |
| type: "POST", |
| url: App.apiPrefix + '/persist', |
| data: JSON.stringify(obj), |
| beforeSend: function () { |
| console.log('BeforeSend: persistKeyValues', obj); |
| } |
| }); |
| }, |
| |
| clusterName: function () { |
| return this.get('content.cluster.name'); |
| }.property('content.cluster.name'), |
| |
| clusterNames: [], |
| |
| // returns an array of existing cluster names. |
| // returns an empty array if there are no existing clusters. |
| getExistingClusterNames: function () { |
| var url = App.apiPrefix + '/clusters'; |
| |
| App.ajax.send({ |
| name: 'wizard.step8.existing_cluster_names', |
| sender: this, |
| success: 'getExistingClusterNamesSuccessCallBack', |
| error: 'getExistingClusterNamesErrorCallback' |
| }); |
| |
| return this.get('clusterNames'); |
| }, |
| |
| getExistingClusterNamesSuccessCallBack: function (data) { |
| var clusterNames = data.items.mapProperty('Clusters.cluster_name'); |
| console.log("Got existing cluster names: " + clusterNames); |
| this.set('clusterNames', clusterNames); |
| }, |
| |
| getExistingClusterNamesErrorCallback: function () { |
| console.log("Failed to get existing cluster names"); |
| this.set('clusterNames', []); |
| }, |
| |
| deleteClusters: function (clusterNames) { |
| clusterNames.forEach(function (clusterName) { |
| App.ajax.send({ |
| name: 'wizard.step8.delete_cluster', |
| sender: this, |
| data: { |
| name: clusterName |
| }, |
| success: 'deleteClustersSuccessCallback', |
| error: 'deleteClustersErrorCallback' |
| }); |
| }, this); |
| }, |
| |
| deleteClustersSuccessCallback: function(data, opt, params) { |
| console.log('DELETE cluster ' + params.name + ' succeeded'); |
| }, |
| deleteClustersErrorCallback: function(request, ajaxOptions, error, opt) { |
| console.log('DELETE cluster failed'); |
| }, |
| |
| |
| /** |
| * Updates local repositories for the Ambari server. |
| */ |
| setLocalRepositories: function () { |
| if (this.get('content.controllerName') !== 'installerController' || !App.supports.localRepositories) { |
| return false; |
| } |
| var self = this; |
| var apiUrl = App.get('stack2VersionURL'); |
| var stacks = this.get('content.stacks'); |
| stacks.forEach(function (stack) { |
| stack.operatingSystems.forEach(function (os) { |
| if (os.baseUrl !== os.originalBaseUrl) { |
| console.log("Updating local repository URL from " + os.originalBaseUrl + " -> " + os.baseUrl + ". ", os); |
| var url = App.apiPrefix + apiUrl + "/operatingSystems/" + os.osType + "/repositories/" + stack.name; |
| self.ajax({ |
| type: 'PUT', |
| url: url, |
| data: JSON.stringify({ |
| "Repositories": { |
| "base_url": os.baseUrl |
| } |
| }), |
| beforeSend: function () { |
| console.log("BeforeSend: setLocalRepositories PUT to ", url); |
| } |
| }); |
| } |
| }); |
| }); |
| }, |
| |
| |
| /** |
| * The following create* functions are called upon submitting Step 8. |
| */ |
| |
| createCluster: function () { |
| |
| if (this.get('content.controllerName') !== 'installerController') { |
| return false; |
| } |
| |
| var clusterName = this.get('clusterName'); |
| var url = App.apiPrefix + '/clusters/' + clusterName; |
| |
| var stackVersion = (this.get('content.installOptions.localRepo')) ? App.currentStackVersion.replace(/(-\d+(\.\d)*)/ig, "Local$&") : App.currentStackVersion; |
| |
| this.ajax({ |
| type: 'POST', |
| url: url, |
| data: JSON.stringify({ "Clusters": {"version": stackVersion }}), |
| beforeSend: function () { |
| console.log("BeforeSend: createCluster for " + clusterName); |
| } |
| }); |
| |
| }, |
| |
| createSelectedServices: function () { |
| |
| var url = App.apiPrefix + '/clusters/' + this.get('clusterName') + '/services'; |
| var data = this.createServiceData(); |
| var httpMethod = 'POST'; |
| |
| if (!data.length) { |
| return; |
| } |
| |
| this.ajax({ |
| type: httpMethod, |
| url: url, |
| data: JSON.stringify(data), |
| beforeSend: function () { |
| console.log('BeforeSend: createSelectedServices ', data); |
| } |
| }); |
| }, |
| |
| createServiceData: function () { |
| var services = this.get('selectedServices').mapProperty('serviceName'); |
| var data = []; |
| services.forEach(function (_service) { |
| data.pushObject({"ServiceInfo": { "service_name": _service }}); |
| }, this); |
| return data; |
| }, |
| |
| createComponents: function () { |
| |
| var serviceComponents = require('data/service_components'); |
| var services = this.get('selectedServices').mapProperty('serviceName'); |
| services.forEach(function (_service) { |
| var components = serviceComponents.filterProperty('service_name', _service); |
| var componentsData = components.map(function (_component) { |
| return { "ServiceComponentInfo": { "component_name": _component.component_name } }; |
| }); |
| |
| // Service must be specified in terms of a query for creating multiple components at the same time. |
| // See AMBARI-1018. |
| var url = App.apiPrefix + '/clusters/' + this.get('clusterName') + '/services?ServiceInfo/service_name=' + _service; |
| var data = { |
| "components": componentsData |
| } |
| |
| this.ajax({ |
| type: 'POST', |
| url: url, |
| data: JSON.stringify(data), |
| beforeSend: function () { |
| console.log('BeforeSend: createComponents for ' + _service, componentsData); |
| } |
| }); |
| }, this); |
| |
| }, |
| |
| registerHostsToCluster: function () { |
| |
| var url = App.apiPrefix + '/clusters/' + this.get('clusterName') + '/hosts'; |
| var data = this.createRegisterHostData(); |
| |
| if (data.length == 0) { |
| return; |
| } |
| |
| this.ajax({ |
| type: 'POST', |
| url: url, |
| data: JSON.stringify(data), |
| beforeSend: function () { |
| console.log('BeforeSend: registerHostsToCluster', data); |
| } |
| }); |
| }, |
| |
| createRegisterHostData: function () { |
| var hosts = this.getRegisteredHosts().filterProperty('isInstalled', false); |
| if (!hosts.length) { |
| return []; |
| } |
| return hosts.map(function (host) { |
| return {"Hosts": { "host_name": host.hostName}}; |
| }); |
| }, |
| |
| // TODO: review the code for add hosts / add services scenarios... |
| createAllHostComponents: function () { |
| |
| var masterHosts = this.get('content.masterComponentHosts'); |
| var slaveHosts = this.get('content.slaveComponentHosts'); |
| var clients = this.get('content.clients'); |
| |
| // note: masterHosts has 'component' vs slaveHosts has 'componentName' |
| var masterComponents = masterHosts.mapProperty('component').uniq(); |
| |
| masterComponents.forEach(function (component) { |
| var hostNames = masterHosts.filterProperty('component', component).filterProperty('isInstalled', false).mapProperty('hostName'); |
| this.registerHostsToComponent(hostNames, component); |
| }, this); |
| |
| slaveHosts.forEach(function (_slave) { |
| if (_slave.componentName !== 'CLIENT') { |
| var hostNames = _slave.hosts.filterProperty('isInstalled', false).mapProperty('hostName'); |
| this.registerHostsToComponent(hostNames, _slave.componentName); |
| } else { |
| clients.forEach(function (_client) { |
| |
| var hostNames = _slave.hosts.mapProperty('hostName'); |
| switch (_client.component_name) { |
| case 'HDFS_CLIENT': |
| // install HDFS_CLIENT on HBASE_MASTER, HBASE_REGIONSERVER, WEBHCAT_SERVER, HISTORYSERVER and OOZIE_SERVER hosts |
| masterHosts.filterProperty('component', 'HBASE_MASTER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'HBASE_REGIONSERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'WEBHCAT_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'HISTORYSERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'OOZIE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'MAPREDUCE_CLIENT': |
| // install MAPREDUCE_CLIENT on HIVE_SERVER, OOZIE_SERVER, NAGIOS_SERVER, and WEBHCAT_SERVER hosts |
| masterHosts.filterProperty('component', 'HIVE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'OOZIE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'NAGIOS_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'WEBHCAT_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'OOZIE_CLIENT': |
| // install OOZIE_CLIENT on NAGIOS_SERVER host |
| masterHosts.filterProperty('component', 'NAGIOS_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'ZOOKEEPER_CLIENT': |
| // install ZOOKEEPER_CLIENT on WEBHCAT_SERVER host |
| masterHosts.filterProperty('component', 'WEBHCAT_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'HIVE_CLIENT': |
| //install HIVE client on NAGIOS_SERVER host |
| masterHosts.filterProperty('component', 'NAGIOS_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'HIVE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'HCAT': |
| // install HCAT (client) on NAGIOS_SERVER host |
| masterHosts.filterProperty('component', 'NAGIOS_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| case 'YARN_CLIENT': |
| // install YARN_CLIENT on NAGIOS_SERVER,HIVE_SERVER,OOZIE_SERVER,WEBHCAT_SERVER host |
| masterHosts.filterProperty('component', 'NAGIOS_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'HIVE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'OOZIE_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| masterHosts.filterProperty('component', 'WEBHCAT_SERVER').filterProperty('isInstalled', false).forEach(function (_masterHost) { |
| hostNames.pushObject(_masterHost.hostName); |
| }, this); |
| break; |
| } |
| hostNames = hostNames.uniq(); |
| |
| if (_client.isInstalled) { |
| //check whether clients are already installed on selected master hosts!!! |
| var installedHosts = _slave.hosts.filterProperty('isInstalled', true).mapProperty('hostName'); |
| installedHosts.forEach(function (host) { |
| if (hostNames.contains(host)) { |
| hostNames.splice(hostNames.indexOf(host), 1); |
| } |
| }, this); |
| } |
| |
| this.registerHostsToComponent(hostNames, _client.component_name); |
| |
| }, this); |
| } |
| }, this); |
| |
| // add Ganglia Monitor (Slave) to all hosts if Ganglia service is selected |
| var gangliaService = this.get('content.services').filterProperty('isSelected', true).findProperty('serviceName', 'GANGLIA'); |
| if (gangliaService) { |
| var hosts = this.getRegisteredHosts(); |
| if (gangliaService.get('isInstalled')) { |
| hosts = hosts.filterProperty('isInstalled', false); |
| } |
| if (hosts.length) { |
| this.registerHostsToComponent(hosts.mapProperty('hostName'), 'GANGLIA_MONITOR'); |
| } |
| } |
| // add MySQL Server if Hive is selected |
| var hiveService = this.get('content.services').filterProperty('isSelected', true).filterProperty('isInstalled', false).findProperty('serviceName', 'HIVE'); |
| if (hiveService) { |
| var hiveDb = this.get('content.serviceConfigProperties').findProperty('name', 'hive_database'); |
| if(hiveDb.value == "New MySQL Database") { |
| this.registerHostsToComponent(masterHosts.filterProperty('component', 'HIVE_SERVER').mapProperty('hostName'), 'MYSQL_SERVER'); |
| } |
| } |
| }, |
| |
| registerHostsToComponent: function (hostNames, componentName) { |
| |
| if (hostNames.length == 0) { |
| return; |
| } |
| console.log('registering ' + componentName + ' to ' + JSON.stringify(hostNames)); |
| |
| // currently we are specifying the predicate as a query string. |
| // this can hit a ~4000-character limit in Jetty server. |
| // chunk to multiple calls if needed |
| // var hostsPredicate = hostNames.map(function (hostName) { |
| // return 'Hosts/host_name=' + hostName; |
| // }).join('|'); |
| |
| var queryStrArr = []; |
| var queryStr = ''; |
| hostNames.forEach(function (hostName) { |
| queryStr += 'Hosts/host_name=' + hostName + '|'; |
| if (queryStr.length > 3500) { |
| queryStrArr.push(queryStr.slice(0, -1)); |
| queryStr = ''; |
| } |
| }); |
| |
| if (queryStr.length > 0) { |
| queryStrArr.push(queryStr.slice(0, -1)); |
| } |
| |
| queryStrArr.forEach(function (queryStr) { |
| // console.log('creating host components for ' + queryStr); |
| var url = App.apiPrefix + '/clusters/' + this.get('clusterName') + '/hosts?' + queryStr; |
| var data = { |
| "host_components": [ |
| { |
| "HostRoles": { |
| "component_name": componentName |
| } |
| } |
| ] |
| }; |
| |
| this.ajax({ |
| type: 'POST', |
| url: url, |
| data: JSON.stringify(data), |
| beforeSend: function () { |
| console.log('BeforeSend: registerHostsToComponent for ' + queryStr + ' and component ' + componentName); |
| } |
| }); |
| }, this); |
| }, |
| |
| createConfigurations: function () { |
| var selectedServices = this.get('selectedServices'); |
| if (this.get('content.controllerName') == 'installerController') { |
| this.get('serviceConfigTags').pushObject(this.createGlobalSiteObj()); |
| this.get('serviceConfigTags').pushObject(this.createCoreSiteObj()); |
| this.get('serviceConfigTags').pushObject(this.createHdfsSiteObj()); |
| } |
| if (selectedServices.someProperty('serviceName', 'MAPREDUCE')) { |
| this.get('serviceConfigTags').pushObject(this.createMrSiteObj()); |
| if (App.supports.capacitySchedulerUi) { |
| this.get('serviceConfigTags').pushObject(this.createCapacityScheduler()); |
| this.get('serviceConfigTags').pushObject(this.createMapredQueueAcls()); |
| } |
| } |
| if (selectedServices.someProperty('serviceName', 'MAPREDUCE2')) { |
| this.get('serviceConfigTags').pushObject(this.createMrSiteObj()); |
| } |
| if (selectedServices.someProperty('serviceName', 'YARN')) { |
| this.get('serviceConfigTags').pushObject(this.createYarnSiteObj()); |
| this.get('serviceConfigTags').pushObject(this.createCapacityScheduler()); |
| } |
| if (selectedServices.someProperty('serviceName', 'HBASE')) { |
| this.get('serviceConfigTags').pushObject(this.createHbaseSiteObj()); |
| } |
| if (selectedServices.someProperty('serviceName', 'OOZIE')) { |
| this.get('serviceConfigTags').pushObject(this.createOozieSiteObj('OOZIE')); |
| } |
| if (selectedServices.someProperty('serviceName', 'HIVE')) { |
| this.get('serviceConfigTags').pushObject(this.createHiveSiteObj('HIVE')); |
| } |
| if (selectedServices.someProperty('serviceName', 'WEBHCAT')) { |
| this.get('serviceConfigTags').pushObject(this.createWebHCatSiteObj('WEBHCAT')); |
| } |
| if (selectedServices.someProperty('serviceName', 'HUE')) { |
| this.get('serviceConfigTags').pushObject(this.createHueSiteObj('HUE')); |
| } |
| this.applyConfigurationsToCluster(); |
| }, |
| |
| applyConfigurationsToCluster: function() { |
| var clusterUrl = App.apiPrefix + '/clusters/' + this.get('clusterName'); |
| var configData = []; |
| this.get('serviceConfigTags').forEach(function (_serviceConfig) { |
| var Clusters = { |
| Clusters: { |
| desired_config: { |
| type: _serviceConfig.type, |
| tag: _serviceConfig.tag, |
| properties: _serviceConfig.properties |
| } |
| } |
| }; |
| configData.pushObject(JSON.stringify(Clusters)); |
| }, this); |
| |
| var data = { |
| configData: '[' + configData.toString() + ']' |
| }; |
| |
| console.debug("applyConfigurationsToCluster(Step8): Applying to URL", clusterUrl, " Data:", data.configData); |
| this.ajax({ |
| type: 'PUT', |
| url: clusterUrl, |
| data: data.configData, |
| beforeSend: function () { |
| console.log("BeforeSend: Updating cluster config"); |
| } |
| }); |
| }, |
| |
| createGlobalSiteObj: function () { |
| var globalSiteProperties = {}; |
| var globalSiteObj = this.get('globals'); |
| var isHCFSSelected = this.get('selectedServices').someProperty('serviceName', 'HCFS'); |
| |
| // screen out the HCFS-specific global config entries when they are not required |
| if (!isHCFSSelected) { |
| globalSiteObj = globalSiteObj.filter(function(_config) { |
| return _config.name.indexOf("fs_glusterfs") < 0; |
| }); |
| } |
| |
| globalSiteObj.forEach(function (_globalSiteObj) { |
| var heapsizeException = ['hadoop_heapsize','yarn_heapsize','nodemanager_heapsize','resourcemanager_heapsize']; |
| // do not pass any globals whose name ends with _host or _hosts |
| if (!/_hosts?$/.test(_globalSiteObj.name)) { |
| // append "m" to JVM memory options except for hadoop_heapsize |
| if (/_heapsize|_newsize|_maxnewsize$/.test(_globalSiteObj.name) && !heapsizeException.contains(_globalSiteObj.name)) { |
| globalSiteProperties[_globalSiteObj.name] = _globalSiteObj.value + "m"; |
| } else { |
| globalSiteProperties[_globalSiteObj.name] = App.config.escapeXMLCharacters(_globalSiteObj.value); |
| } |
| console.log("STEP8: name of the global property is: " + _globalSiteObj.name); |
| console.log("STEP8: value of the global property is: " + _globalSiteObj.value); |
| } |
| if (_globalSiteObj.name == 'java64_home') { |
| globalSiteProperties['java64_home'] = this.get('content.installOptions.javaHome'); |
| } |
| this._recordHostOverrideFromObj(_globalSiteObj, 'global', 'version1', this); |
| }, this); |
| // we don't expose gmond_user to the user; it needs to be the same as gmetad_user |
| globalSiteProperties['gmond_user'] = globalSiteProperties['gmetad_user']; |
| return {"type": "global", "tag": "version1", "properties": globalSiteProperties}; |
| }, |
| |
| createCoreSiteObj: function () { |
| var coreSiteObj = this.get('configs').filterProperty('filename', 'core-site.xml'); |
| var coreSiteProperties = {}; |
| // hadoop.proxyuser.oozie.hosts needs to be skipped if oozie is not selected |
| var isOozieSelected = this.get('selectedServices').someProperty('serviceName', 'OOZIE'); |
| var oozieUser = this.get('globals').someProperty('name', 'oozie_user') ? this.get('globals').findProperty('name', 'oozie_user').value : null; |
| var isHiveSelected = this.get('selectedServices').someProperty('serviceName', 'HIVE'); |
| var hiveUser = this.get('globals').someProperty('name', 'hive_user') ? this.get('globals').findProperty('name', 'hive_user').value : null; |
| var isHcatSelected = this.get('selectedServices').someProperty('serviceName', 'WEBHCAT'); |
| var hcatUser = this.get('globals').someProperty('name', 'hcat_user') ? this.get('globals').findProperty('name', 'hcat_user').value : null; |
| var isHCFSSelected = this.get('selectedServices').someProperty('serviceName', 'HCFS'); |
| |
| // screen out the HCFS-specific core-site.xml entries when they are not needed |
| if (!isHCFSSelected) { |
| coreSiteObj = coreSiteObj.filter(function(_config) { |
| return _config.name.indexOf("fs.glusterfs") < 0; |
| }); |
| } |
| coreSiteObj.forEach(function (_coreSiteObj) { |
| if ((isOozieSelected || (_coreSiteObj.name != 'hadoop.proxyuser.' + oozieUser + '.hosts' && _coreSiteObj.name != 'hadoop.proxyuser.' + oozieUser + '.groups')) && (isHiveSelected || (_coreSiteObj.name != 'hadoop.proxyuser.' + hiveUser + '.hosts' && _coreSiteObj.name != 'hadoop.proxyuser.' + hiveUser + '.groups')) && (isHcatSelected || (_coreSiteObj.name != 'hadoop.proxyuser.' + hcatUser + '.hosts' && _coreSiteObj.name != 'hadoop.proxyuser.' + hcatUser + '.groups'))) { |
| coreSiteProperties[_coreSiteObj.name] = App.config.escapeXMLCharacters(_coreSiteObj.value); |
| this._recordHostOverrideFromObj(_coreSiteObj, 'core-site', 'version1', this); |
| } |
| if (isHCFSSelected && _coreSiteObj.name == "fs.default.name") { |
| coreSiteProperties[_coreSiteObj.name] = this.get('globals').someProperty('name', 'fs_glusterfs_default_name') ? App.config.escapeXMLCharacters(this.get('globals').findProperty('name', 'fs_glusterfs_default_name').value) : null; |
| } |
| console.log("STEP*: name of the property is: " + _coreSiteObj.name); |
| console.log("STEP8: value of the property is: " + _coreSiteObj.value); |
| }, this); |
| return {"type": "core-site", "tag": "version1", "properties": coreSiteProperties}; |
| }, |
| |
| createHdfsSiteObj: function () { |
| var hdfsSiteObj = this.get('configs').filterProperty('filename', 'hdfs-site.xml'); |
| var hdfsProperties = {}; |
| hdfsSiteObj.forEach(function (_configProperty) { |
| hdfsProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'hdfs-site', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {"type": "hdfs-site", "tag": "version1", "properties": hdfsProperties }; |
| }, |
| |
| createHueSiteObj: function () { |
| var hueSiteObj = this.get('configs').filterProperty('filename', 'hue-site.xml'); |
| var hueProperties = {}; |
| hueSiteObj.forEach(function (_configProperty) { |
| hueProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'hue-site', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {"type": "hue-site", "tag": "version1", "properties": hueProperties }; |
| }, |
| |
| createMrSiteObj: function () { |
| var configs = this.get('configs').filterProperty('filename', 'mapred-site.xml'); |
| var mrProperties = {}; |
| configs.forEach(function (_configProperty) { |
| mrProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'mapred-site', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {type: 'mapred-site', tag: 'version1', properties: mrProperties}; |
| }, |
| |
| createYarnSiteObj: function () { |
| var configs = this.get('configs').filterProperty('filename', 'yarn-site.xml'); |
| var mrProperties = {}; |
| configs.forEach(function (_configProperty) { |
| mrProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'yarn-site', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {type: 'yarn-site', tag: 'version1', properties: mrProperties}; |
| }, |
| |
| createCapacityScheduler: function () { |
| var configs = this.get('configs').filterProperty('filename', 'capacity-scheduler.xml'); |
| var csProperties = {}; |
| configs.forEach(function (_configProperty) { |
| csProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'capacity-scheduler', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {type: 'capacity-scheduler', tag: 'version1', properties: csProperties}; |
| }, |
| |
| createMapredQueueAcls: function () { |
| var configs = this.get('configs').filterProperty('filename', 'mapred-queue-acls.xml'); |
| var mqProperties = {}; |
| configs.forEach(function (_configProperty) { |
| mqProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'mapred-queue-acls', 'version1', this); |
| console.log("STEP*: name of the property is: " + _configProperty.name); |
| console.log("STEP8: value of the property is: " + _configProperty.value); |
| }, this); |
| return {type: 'mapred-queue-acls', tag: 'version1', properties: mqProperties}; |
| }, |
| |
| createHbaseSiteObj: function () { |
| var configs = this.get('configs').filterProperty('filename', 'hbase-site.xml'); |
| var hbaseProperties = {}; |
| configs.forEach(function (_configProperty) { |
| hbaseProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'hbase-site', 'version1', this); |
| }, this); |
| return {type: 'hbase-site', tag: 'version1', properties: hbaseProperties}; |
| }, |
| |
| createOozieSiteObj: function (serviceName) { |
| var configs = this.get('configs').filterProperty('filename', 'oozie-site.xml'); |
| var oozieProperties = {}; |
| configs.forEach(function (_configProperty) { |
| oozieProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'oozie-site', 'version1', this); |
| }, this); |
| var globals = this.get('content.serviceConfigProperties').filterProperty('id', 'puppet var'); |
| if (globals.someProperty('name', 'oozie_database')) { |
| var oozieDb = globals.findProperty('name', 'oozie_database'); |
| if (oozieDb.value === 'New Derby Database') { |
| // oozieProperties["oozie.service.JPAService.jdbc.url"] = "jdbc:derby:${oozie.data.dir}/${oozie.db.schema.name}-db;create=true"; |
| oozieProperties["oozie.service.JPAService.jdbc.driver"] = "org.apache.derby.jdbc.EmbeddedDriver"; |
| } else if (oozieDb.value === 'Existing MySQL Database') { |
| // oozieProperties["oozie.service.JPAService.jdbc.url"] = "jdbc:mysql://" + oozieHost + "/" + oozieDbName; |
| oozieProperties["oozie.service.JPAService.jdbc.driver"] = "com.mysql.jdbc.Driver"; |
| } else { //existing oracle database |
| // oozieProperties["oozie.service.JPAService.jdbc.url"] = "jdbc:oracle:thin:@//" + oozieHost + ":1521/" + oozieDbName; |
| oozieProperties["oozie.service.JPAService.jdbc.driver"] = "oracle.jdbc.driver.OracleDriver"; |
| } |
| } |
| return {type: 'oozie-site', tag: 'version1', properties: oozieProperties}; |
| }, |
| |
| createHiveSiteObj: function (serviceName) { |
| var configs = this.get('configs').filterProperty('filename', 'hive-site.xml'); |
| var hiveProperties = {}; |
| configs.forEach(function (_configProperty) { |
| hiveProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'hive-site', 'version1', this); |
| }, this); |
| var globals = this.get('content.serviceConfigProperties').filterProperty('id', 'puppet var'); |
| if (globals.someProperty('name', 'hive_database')) { |
| var hiveDb = globals.findProperty('name', 'hive_database'); |
| var hiveHost = globals.findProperty('name', 'hive_hostname').value; |
| var hiveDbName = globals.findProperty('name', 'hive_database_name').value; |
| if (hiveDb.value === 'New MySQL Database') { |
| // hiveProperties["javax.jdo.option.ConnectionURL"] = "jdbc:mysql://"+ hiveHost + "/" + hiveDbName + "?createDatabaseIfNotExist=true"; |
| hiveProperties["javax.jdo.option.ConnectionDriverName"] = "com.mysql.jdbc.Driver"; |
| } else if (hiveDb.value === 'Existing MySQL Database'){ |
| // hiveProperties["javax.jdo.option.ConnectionURL"] = "jdbc:mysql://"+ hiveHost + "/" + hiveDbName + "?createDatabaseIfNotExist=true"; |
| hiveProperties["javax.jdo.option.ConnectionDriverName"] = "com.mysql.jdbc.Driver"; |
| } else { //existing oracle database |
| // hiveProperties["javax.jdo.option.ConnectionURL"] = "jdbc:oracle:thin:@//"+ hiveHost + ":1521/" + hiveDbName; |
| hiveProperties["javax.jdo.option.ConnectionDriverName"] = "oracle.jdbc.driver.OracleDriver"; |
| } |
| } |
| return {type: 'hive-site', tag: 'version1', properties: hiveProperties}; |
| }, |
| |
| createWebHCatSiteObj: function (serviceName) { |
| var configs = this.get('configs').filterProperty('filename', 'webhcat-site.xml'); |
| var webHCatProperties = {}; |
| configs.forEach(function (_configProperty) { |
| webHCatProperties[_configProperty.name] = App.config.escapeXMLCharacters(_configProperty.value); |
| this._recordHostOverrideFromObj(_configProperty, 'webhcat-site', 'version1', this); |
| }, this); |
| return {type: 'webhcat-site', tag: 'version1', properties: webHCatProperties}; |
| }, |
| |
| ajaxQueueFinished: function () { |
| //do something |
| }, |
| |
| doNextAjaxCall: function () { |
| |
| if (this.get('ajaxBusy')) { |
| return; |
| } |
| |
| var queue = this.get('ajaxQueue'); |
| if (!queue.length) { |
| this.ajaxQueueFinished(); |
| return; |
| } |
| |
| var first = queue[0]; |
| this.set('ajaxQueue', queue.slice(1)); |
| this.set('ajaxQueueLeft', this.get('ajaxQueue').length); |
| |
| this.set('ajaxBusy', true); |
| console.log('AJAX send ' + first.url); |
| $.ajax(first); |
| |
| }, |
| |
| /** |
| * Records all the host overrides per site/tag |
| */ |
| _recordHostOverrideFromObj: function(serviceConfigObj, siteName, tagName, self){ |
| var overrides = serviceConfigObj.overrides; |
| if(overrides && overrides.length>0){ |
| overrides.forEach(function(override){ |
| override.hosts.forEach(function(host){ |
| if(!(host in self.savedHostToOverrideSiteToTagMap)){ |
| self.savedHostToOverrideSiteToTagMap[host] = {}; |
| } |
| if(!(siteName in self.savedHostToOverrideSiteToTagMap[host])){ |
| self.savedHostToOverrideSiteToTagMap[host][siteName] = {}; |
| self.savedHostToOverrideSiteToTagMap[host][siteName].map = {}; |
| } |
| var finalTag = tagName + '_' + host; |
| console.log("recordHostOverride(): Saving host override for host="+host+", site="+siteName+", tag="+finalTag+", (key,value)=("+serviceConfigObj.name+","+override.value+")"); |
| self.savedHostToOverrideSiteToTagMap[host][siteName].tagName = finalTag; |
| self.savedHostToOverrideSiteToTagMap[host][siteName].map[serviceConfigObj.name] = override.value; |
| }); |
| }); |
| } |
| }, |
| |
| /** |
| * Creates host level overrides for service configuration. |
| * |
| */ |
| createHostOverrideConfigurations: function () { |
| var singlePUTHostData = []; |
| var savedHostSiteArray = []; |
| for ( var host in this.savedHostToOverrideSiteToTagMap) { |
| for ( var siteName in this.savedHostToOverrideSiteToTagMap[host]) { |
| var tagName = this.savedHostToOverrideSiteToTagMap[host][siteName].tagName; |
| var map = this.savedHostToOverrideSiteToTagMap[host][siteName].map; |
| savedHostSiteArray.push(host + "///" + siteName); |
| singlePUTHostData.push({ |
| RequestInfo: { |
| query: 'Hosts/host_name='+host |
| }, |
| Body: { |
| Hosts: { |
| desired_config: { |
| type: siteName, |
| tag: tagName, |
| properties: map |
| } |
| } |
| } |
| }); |
| } |
| } |
| console.log("createHostOverrideConfigSites(): PUTting host-overrides. Data=", singlePUTHostData); |
| if(singlePUTHostData.length>0){ |
| var url = App.apiPrefix + '/clusters/' + this.get('clusterName') + '/hosts'; |
| this.ajax({ |
| type: 'PUT', |
| url: url, |
| data: JSON.stringify(singlePUTHostData), |
| dataType: 'text', |
| beforeSend: function () { |
| console.log("createHostOverrideConfigSites() PUT override=", singlePUTHostData); |
| } |
| }); |
| } |
| }, |
| |
| /** |
| * We need to do a lot of ajax calls async in special order. To do this, |
| * generate array of ajax objects and then send requests step by step. All |
| * ajax objects are stored in <code>ajaxQueue</code> |
| * |
| * @param params |
| */ |
| |
| ajax: function (params) { |
| if (App.testMode) return; |
| |
| var self = this; |
| params = jQuery.extend({ |
| async: true, |
| dataType: 'text', |
| statusCode: require('data/statusCodes'), |
| timeout: App.timeout, |
| error: function (request, ajaxOptions, error) { |
| console.log('Step8: In Error '); |
| // console.log('Step8: Error message is: ' + request.responseText); |
| }, |
| success: function (data) { |
| var jsonData = jQuery.parseJSON(data); |
| console.log("TRACE: STep8 -> In success function"); |
| console.log("TRACE: STep8 -> value of the url is: " + params.url); |
| console.log("TRACE: STep8 -> value of the received data is: " + jsonData); |
| } |
| }, params); |
| |
| var success = params.success; |
| var error = params.error; |
| |
| params.success = function () { |
| if (success) { |
| success(); |
| } |
| |
| self.set('ajaxBusy', false); |
| self.doNextAjaxCall(); |
| } |
| |
| params.error = function (xhr, status, error) { |
| var responseText = JSON.parse(xhr.responseText); |
| var controller = App.router.get(App.clusterStatus.wizardControllerName); |
| controller.registerErrPopup(Em.I18n.t('common.error'), responseText.message); |
| self.set('hasErrorOccurred', true); |
| // an error will break the ajax call chain and allow submission again |
| self.set('isSubmitDisabled', false); |
| self.set('isBackBtnDisabled', false); |
| App.router.get(self.get('content.controllerName')).setStepsEnable(); |
| self.get('ajaxQueue').clear(); |
| self.set('ajaxBusy', false); |
| } |
| this.get('ajaxQueue').pushObject(params); |
| } |
| |
| }); |
