diff --git a/docs/changelog/86580.yaml b/docs/changelog/86580.yaml new file mode 100644 index 0000000000000..0cbf592302ef3 --- /dev/null +++ b/docs/changelog/86580.yaml @@ -0,0 +1,6 @@ +pr: 86580 +summary: Correctly calculate disk usage for frozen data tier telemetry +area: Stats +type: bug +issues: + - 86055 diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/DataTiersUsageTransportAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/DataTiersUsageTransportAction.java index 7c419433cfbdc..4c77b35e619b0 100644 --- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/DataTiersUsageTransportAction.java +++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/DataTiersUsageTransportAction.java @@ -203,7 +203,7 @@ private static void aggregateDataTierShardStats(NodeStats nodeStats, Index index final List allShardStats = nodeStats.getIndices().getShardStats(index); if (allShardStats != null) { for (IndexShardStats shardStat : allShardStats) { - accumulator.totalByteCount += shardStat.getTotal().getStore().getSizeInBytes(); + accumulator.totalByteCount += shardStat.getTotal().getStore().totalDataSetSizeInBytes(); accumulator.docCount += shardStat.getTotal().getDocs().getCount(); // Accumulate stats about started shards @@ -215,7 +215,7 @@ private static void aggregateDataTierShardStats(NodeStats nodeStats, Index index if (primaryStoreStats != null) { // if primaryStoreStats is null, it means there is no primary on the node in question accumulator.primaryShardCount++; - long primarySize = primaryStoreStats.getSizeInBytes(); + long primarySize = primaryStoreStats.totalDataSetSizeInBytes(); accumulator.primaryByteCount += primarySize; accumulator.valueSketch.add(primarySize); } diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/DataTiersUsageTransportActionTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/DataTiersUsageTransportActionTests.java index aa86f29a549f7..8a2b819b9d4a9 100644 --- a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/DataTiersUsageTransportActionTests.java +++ b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/DataTiersUsageTransportActionTests.java @@ -775,7 +775,7 @@ private List buildNodeStats(ClusterState clusterState, long bytesPerS } private static ShardStats shardStat(long byteCount, long docCount, ShardRouting routing) { - StoreStats storeStats = new StoreStats(byteCount, 0L, 0L); + StoreStats storeStats = new StoreStats(randomNonNegativeLong(), byteCount, 0L); DocsStats docsStats = new DocsStats(docCount, 0L, byteCount); CommonStats commonStats = new CommonStats(CommonStatsFlags.ALL);