Report shard failures in the field_capabilities response

elastic · Apr 28, 2017 · 950a4e7 · 950a4e7
1 parent 5ba57f7
commit 950a4e7
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/src/core_plugins/kibana/server/routes/api/ingest/register_field_capabilities.js b/src/core_plugins/kibana/server/routes/api/ingest/register_field_capabilities.js
@@ -22,7 +22,12 @@ export function registerFieldCapabilities(server) {
             return _.pick(value, ['searchable', 'aggregatable']);
           });
 
-          reply({ fields: fieldsFilteredValues });
+          const retVal = { fields: fieldsFilteredValues };
+          if (res._shards && res._shards.failed) {
+            retVal.shard_failure_response = res;
+          }
+
+          reply(retVal);
         },
         (error) => {
           reply(handleESError(error));

diff --git a/src/ui/public/index_patterns/_enhance_fields_with_capabilities.js b/src/ui/public/index_patterns/_enhance_fields_with_capabilities.js
@@ -1,11 +1,20 @@
 import chrome from 'ui/chrome';
 import _ from 'lodash';
+import { Notifier } from 'ui/notify/notifier';
+import { ShardFailure } from 'ui/errors';
 
 export function EnhanceFieldsWithCapabilitiesProvider($http) {
+  const notifier = new Notifier({
+    location: 'Field Capabilities'
+  });
 
   return function (fields, indices) {
     return $http.get(chrome.addBasePath(`/api/kibana/${indices}/field_capabilities`))
     .then((res) => {
+      if (_.get(res, 'data.shard_failure_response')) {
+        notifier.warning(new ShardFailure(res.data.shard_failure_response));
+      }
+
       const stats = _.get(res, 'data.fields', {});
 
       return _.map(fields, (field) => {