AMBARI-17731. Capacity Scheduler View - Fix for nodelabel api compatibility issue in HDP-2.5 (Akhil PB via pallavkul)

contrib/views/capacity-scheduler/src/main/resources/ui/app/adapters.js

@@ -243,8 +243,11 @@ App.QueueAdapter = DS.Adapter.extend({
     },'App: QueueAdapter#findAllTagged ' + tag);
   },
 
-  getNodeLabels:function () {
+  getNodeLabels:function (store) {
     var uri = [_getCapacitySchedulerViewUri(this),'nodeLabels'].join('/');
+    var stackId = store.get('stackId'),
+    stackVersion = stackId.substr(stackId.indexOf('-') + 1);
+
     if (App.testMode)
       uri = uri + ".json";
 
@@ -252,15 +255,25 @@ App.QueueAdapter = DS.Adapter.extend({
       _ajax(uri,'GET').then(function(data) {
         var parsedData = JSON.parse(data), labels;
 
-        if (parsedData && Em.isArray(parsedData.nodeLabels)) {
-          labels = parsedData.nodeLabels;
+        if (stackVersion >= 2.5) {
+          if (parsedData && Em.isArray(parsedData.nodeLabelInfo)) {
+            labels = parsedData.nodeLabelInfo;
+          } else {
+            labels = (parsedData && parsedData.nodeLabelInfo)?[parsedData.nodeLabelInfo]:[];
+          }
+          Ember.run(null, resolve, labels.map(function (label) {
+            return {name:label.name,exclusivity:label.exclusivity};
+          }));
         } else {
-          labels = (parsedData && parsedData.nodeLabels)?[parsedData.nodeLabels]:[];
+          if (parsedData && Em.isArray(parsedData.nodeLabels)) {
+            labels = parsedData.nodeLabels;
+          } else {
+            labels = (parsedData && parsedData.nodeLabels)?[parsedData.nodeLabels]:[];
+          }
+          Ember.run(null, resolve, labels.map(function (label) {
+            return {name:label};
+          }));
         }
-
-        Ember.run(null, resolve, labels.map(function (label) {
-          return {name:label};
-        }));
       }, function(jqXHR) {
         jqXHR.then = null;
         Ember.run(null, reject, jqXHR);
@@ -282,12 +295,15 @@ App.QueueAdapter = DS.Adapter.extend({
     }.bind(this),'App: QueueAdapter#getPrivilege');
   },
 
-  checkCluster:function () {
+  checkCluster:function (store) {
     var uri = [_getCapacitySchedulerViewUri(this),'cluster'].join('/');
     if (App.testMode)
       uri = uri + ".json";
     return new Ember.RSVP.Promise(function(resolve, reject) {
       _ajax(uri,'GET').then(function(data) {
+        if (data && data.Clusters && data.Clusters.version) {
+          store.set("stackId", data.Clusters.version);
+        }
         Ember.run(null, resolve, data);
       }, function(jqXHR) {
         if (jqXHR.status === 404) {
@@ -331,4 +347,3 @@ App.TagAdapter = App.QueueAdapter.extend({
     }, "App: TagAdapter#findAll " + type);
   }
 });
-

contrib/views/capacity-scheduler/src/main/resources/ui/app/store.js

@@ -117,6 +117,8 @@ App.ApplicationStore = DS.Store.extend({
 
   current_tag: '',
 
+  stackId: '',
+
   hasDeletedQueues:Em.computed.notEmpty('deletedQueues.[]'),
 
   deletedQueues:[],
@@ -287,7 +289,7 @@ App.ApplicationStore = DS.Store.extend({
     var adapter = this.get('defaultAdapter'),
         store = this,
         promise = new Ember.RSVP.Promise(function(resolve, reject) {
-          adapter.getNodeLabels().then(function(data) {
+          adapter.getNodeLabels(store).then(function(data) {
             store.set('isRmOffline',false);
             resolve(data);
           }, function() {
@@ -376,6 +378,6 @@ App.ApplicationStore = DS.Store.extend({
     return this.get('defaultAdapter').getPrivilege();
   },
   checkCluster:function () {
-    return this.get('defaultAdapter').checkCluster();
+    return this.get('defaultAdapter').checkCluster(this);
   }
 });