diff --git a/x-pack/plugins/monitoring/server/lib/metrics/__snapshots__/metrics.test.js.snap b/x-pack/plugins/monitoring/server/lib/metrics/__snapshots__/metrics.test.js.snap
index 24d9d52224fa4..242bfaeaffb6b 100644
--- a/x-pack/plugins/monitoring/server/lib/metrics/__snapshots__/metrics.test.js.snap
+++ b/x-pack/plugins/monitoring/server/lib/metrics/__snapshots__/metrics.test.js.snap
@@ -5981,7 +5981,7 @@ Object {
     "isNotSupportedInInternalCollection": undefined,
     "label": "Pipeline Node Count",
     "legendFormat": undefined,
-    "mbField": undefined,
+    "mbField": "logstash.node.stats.logstash.uuid",
     "metricAgg": undefined,
     "periodsField": undefined,
     "quotaField": undefined,
@@ -6437,7 +6437,7 @@ Object {
     "isNotSupportedInInternalCollection": undefined,
     "label": "Pipeline Node Count",
     "legendFormat": undefined,
-    "mbField": undefined,
+    "mbField": "logstash.node.stats.logstash.uuid",
     "metricAgg": undefined,
     "periodsField": undefined,
     "quotaField": undefined,
diff --git a/x-pack/plugins/monitoring/server/lib/metrics/logstash/classes.ts b/x-pack/plugins/monitoring/server/lib/metrics/logstash/classes.ts
index fd150864c6b2e..b1240a2ca9798 100644
--- a/x-pack/plugins/monitoring/server/lib/metrics/logstash/classes.ts
+++ b/x-pack/plugins/monitoring/server/lib/metrics/logstash/classes.ts
@@ -7,11 +7,11 @@
 
 /* eslint-disable max-classes-per-file */
 
-import _ from 'lodash';
 import { i18n } from '@kbn/i18n';
-import { ClusterMetric, Metric, MetricOptions } from '../classes';
-import { LARGE_FLOAT } from '../../../../common/formatting';
+import _ from 'lodash';
 import { NORMALIZED_DERIVATIVE_UNIT } from '../../../../common/constants';
+import { LARGE_FLOAT } from '../../../../common/formatting';
+import { ClusterMetric, Metric, MetricOptions } from '../classes';
 
 const msTimeUnitLabel = i18n.translate('xpack.monitoring.metrics.logstash.msTimeUnitLabel', {
   defaultMessage: 'ms',
@@ -411,7 +411,7 @@ export class LogstashPipelineThroughputMetric extends LogstashMetric {
 
 type LogstashPipelineNodeCountMetricOptions = Pick<
   MetricOptions,
-  'field' | 'label' | 'description' | 'format' | 'units'
+  'field' | 'label' | 'mbField' | 'description' | 'format' | 'units'
 > &
   Partial<Pick<MetricOptions, 'uuidField'>>;
 
@@ -427,15 +427,10 @@ export class LogstashPipelineNodeCountMetric extends LogstashMetric {
     }: {
       pageOfPipelines: Array<{ id: string }>;
     }) => {
-      const termAggExtras: {
-        include: string[];
-      } = {
-        include: [],
-      };
+      const include: string[] | undefined = pageOfPipelines?.length
+        ? pageOfPipelines.map((pipeline) => pipeline.id)
+        : undefined;
 
-      if (pageOfPipelines) {
-        termAggExtras.include = pageOfPipelines.map((pipeline) => pipeline.id);
-      }
       return {
         pipelines_nested: {
           nested: {
@@ -446,7 +441,7 @@ export class LogstashPipelineNodeCountMetric extends LogstashMetric {
               terms: {
                 field: 'logstash_stats.pipelines.id',
                 size: 1000,
-                ...termAggExtras,
+                include,
               },
               aggs: {
                 to_root: {
@@ -472,7 +467,7 @@ export class LogstashPipelineNodeCountMetric extends LogstashMetric {
               terms: {
                 field: 'logstash.node.stats.pipelines.id',
                 size: 1000,
-                ...termAggExtras,
+                include,
               },
               aggs: {
                 to_root: {
@@ -480,7 +475,7 @@ export class LogstashPipelineNodeCountMetric extends LogstashMetric {
                   aggs: {
                     node_count: {
                       cardinality: {
-                        field: this.field,
+                        field: this.mbField,
                       },
                     },
                   },
diff --git a/x-pack/plugins/monitoring/server/lib/metrics/logstash/metrics.ts b/x-pack/plugins/monitoring/server/lib/metrics/logstash/metrics.ts
index 97119289d2139..73aa91ef6f5fa 100644
--- a/x-pack/plugins/monitoring/server/lib/metrics/logstash/metrics.ts
+++ b/x-pack/plugins/monitoring/server/lib/metrics/logstash/metrics.ts
@@ -6,23 +6,23 @@
  */
 
 import { i18n } from '@kbn/i18n';
+import {
+  LARGE_ABBREVIATED,
+  LARGE_BYTES,
+  LARGE_FLOAT,
+  SMALL_BYTES,
+} from '../../../../common/formatting';
 import { QuotaMetric } from '../classes';
 import {
-  LogstashEventsRateClusterMetric,
   LogstashEventsLatencyClusterMetric,
-  LogstashEventsRateMetric,
   LogstashEventsLatencyMetric,
+  LogstashEventsRateClusterMetric,
+  LogstashEventsRateMetric,
   LogstashMetric,
+  LogstashPipelineNodeCountMetric,
   LogstashPipelineQueueSizeMetric,
   LogstashPipelineThroughputMetric,
-  LogstashPipelineNodeCountMetric,
 } from './classes';
-import {
-  LARGE_FLOAT,
-  LARGE_BYTES,
-  SMALL_BYTES,
-  LARGE_ABBREVIATED,
-} from '../../../../common/formatting';
 
 const instanceSystemLoadTitle = i18n.translate(
   'xpack.monitoring.metrics.logstash.systemLoadTitle',
@@ -451,6 +451,7 @@ export const metrics = {
   logstash_cluster_pipeline_nodes_count: new LogstashPipelineNodeCountMetric({
     field: 'logstash_stats.logstash.uuid',
     label: pipelineNodeCountLabel,
+    mbField: 'logstash.node.stats.logstash.uuid',
     description: pipelineNodeCountDescription,
     format: LARGE_FLOAT,
     units: '',
@@ -459,6 +460,7 @@ export const metrics = {
     uuidField: 'logstash_stats.logstash.uuid', // TODO: add comment explaining why
     field: 'logstash_stats.logstash.uuid',
     label: pipelineNodeCountLabel,
+    mbField: 'logstash.node.stats.logstash.uuid',
     description: pipelineNodeCountDescription,
     format: LARGE_FLOAT,
     units: '',