diff --git a/src/main/java/org/elasticsearch/enterprise/monitor/exporter/ESExporter.java b/src/main/java/org/elasticsearch/enterprise/monitor/exporter/ESExporter.java index 2164da90545..0f2ac1dd714 100644 --- a/src/main/java/org/elasticsearch/enterprise/monitor/exporter/ESExporter.java +++ b/src/main/java/org/elasticsearch/enterprise/monitor/exporter/ESExporter.java @@ -88,13 +88,13 @@ public class ESExporter extends AbstractLifecycleComponent implement @Override public void exportNodeStats(NodeStats nodeStats) { nodeStatsRenderer.reset(nodeStats); - exportXContent("nodestats", nodeStatsRenderer); + exportXContent("node_stats", nodeStatsRenderer); } @Override public void exportShardStats(ShardStats[] shardStatsArray) { shardStatsRenderer.reset(shardStatsArray); - exportXContent("shardstats", shardStatsRenderer); + exportXContent("shard_stats", shardStatsRenderer); } @@ -342,9 +342,9 @@ public class ESExporter extends AbstractLifecycleComponent implement builder.startObject(); builder.field("@timestamp", defaultDatePrinter.print(collectionTime)); ShardRouting shardRouting = stats[index].getShardRouting(); - builder.field("id", shardRouting.id()); builder.field("index", shardRouting.index()); - builder.field("status", shardRouting.state()); + builder.field("shard_id", shardRouting.id()); + builder.field("shard_state", shardRouting.state()); builder.field("primary", shardRouting.primary()); addNodeInfo(builder); stats[index].getStats().toXContent(builder, xContentParams);