adapt ES queries to updated document structure

kibanamachine · Dec 20, 2021 · 25d4357 · 25d4357
1 parent 2fa5a87
commit 25d4357
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 5 deletions.
diff --git a/x-pack/plugins/monitoring/public/components/elasticsearch/shard_activity/parse_props.js b/x-pack/plugins/monitoring/public/components/elasticsearch/shard_activity/parse_props.js
@@ -29,6 +29,7 @@ export const parseProps = (props) => {
     stage,
     index,
     index_name: indexName,
+    name: mbIndexName,
     primary: isPrimary,
     start_time_in_millis: startTimeInMillis,
     total_time_in_millis: totalTimeInMillis,
@@ -42,7 +43,7 @@ export const parseProps = (props) => {
   const { files, size } = index;
 
   return {
-    name: indexName || index.name,
+    name: indexName || mbIndexName,
     shard: `${id} / ${isPrimary ? 'Primary' : 'Replica'}`,
     relocationType: type === 'PRIMARY_RELOCATION' ? 'Primary Relocation' : normalizeString(type),
     stage: normalizeString(stage),

diff --git a/x-pack/plugins/monitoring/server/lib/cluster/get_clusters_state.ts b/x-pack/plugins/monitoring/server/lib/cluster/get_clusters_state.ts
@@ -71,7 +71,7 @@ export function getClustersState(
       'hits.hits._source.cluster_uuid',
       'hits.hits._source.elasticsearch.cluster.id',
       'hits.hits._source.cluster_state',
-      'hits.hits._source.elasticsearch.cluster.stats.state',
+      'hits.hits._source.elasticsearch.cluster.state',
     ],
     body: {
       query: {

diff --git a/x-pack/plugins/monitoring/server/lib/elasticsearch/get_last_recovery.ts b/x-pack/plugins/monitoring/server/lib/elasticsearch/get_last_recovery.ts
@@ -110,7 +110,7 @@ export async function getLastRecovery(
     },
   };
   const mbParams = {
-    index: mbIndexPattern,
+    index: esIndexPattern,
     size,
     ignore_unavailable: true,
     body: {

diff --git a/.../plugins/monitoring/server/lib/elasticsearch/shards/get_indices_unassigned_shard_stats.ts b/.../plugins/monitoring/server/lib/elasticsearch/shards/get_indices_unassigned_shard_stats.ts
@@ -32,7 +32,7 @@ async function getUnassignedShardData(
   } else if (cluster.elasticsearch?.cluster?.stats?.state?.state_uuid) {
     filters.push({
       term: {
-        'elasticsearch.cluster.stats.state.state_uuid':
+        'elasticsearch.cluster.state.id':
           cluster.elasticsearch?.cluster?.stats?.state?.state_uuid,
       },
     });

diff --git a/x-pack/plugins/monitoring/server/lib/elasticsearch/shards/get_nodes_shard_count.ts b/x-pack/plugins/monitoring/server/lib/elasticsearch/shards/get_nodes_shard_count.ts
@@ -30,7 +30,7 @@ async function getShardCountPerNode(
   } else if (cluster.elasticsearch?.cluster?.stats?.state?.state_uuid) {
     filters.push({
       term: {
-        'elasticsearch.cluster.stats.state.state_uuid':
+        'elasticsearch.cluster.state.id':
           cluster.elasticsearch?.cluster?.stats?.state?.state_uuid,
       },
     });