From 71607f4b7d60f63a52474aca9c3ffc2c9e9b0ef1 Mon Sep 17 00:00:00 2001 From: Peter Xu Date: Fri, 30 Aug 2024 22:32:18 -0400 Subject: [PATCH] more debug --- .../db/points/DataPointArchiveRocksDB.java | 26 ++++++++++++++++++- 1 file changed, 25 insertions(+), 1 deletion(-) diff --git a/carbonj.service/src/main/java/com/demandware/carbonj/service/db/points/DataPointArchiveRocksDB.java b/carbonj.service/src/main/java/com/demandware/carbonj/service/db/points/DataPointArchiveRocksDB.java index 270194c9..fdcb6a7b 100644 --- a/carbonj.service/src/main/java/com/demandware/carbonj/service/db/points/DataPointArchiveRocksDB.java +++ b/carbonj.service/src/main/java/com/demandware/carbonj/service/db/points/DataPointArchiveRocksDB.java @@ -297,21 +297,45 @@ public int put( DataPoints points ) try { for (int i = 0, n = points.size(); i < n; i++) { DataPoint p = points.get(i); + if (p.name != null && p.name.startsWith("pod222.ecom_ag.bjmr.bjmr_prd") && p.name.endsWith("number-of-filters.max")) { + log.warn("============"); + log.warn("Received aggregated metric " + p.name); + log.warn(p.toString()); + log.warn("============"); + } if (!p.isValid()) { + if (p.name != null && p.name.startsWith("pod222.ecom_ag.bjmr.bjmr_prd") && p.name.endsWith("number-of-filters.max")) { + log.warn("============"); + log.warn("Invalid aggregated metric " + p.name); + log.warn(p.toString()); + log.warn("============"); + } continue; } if (!p.hasMetricId()) { + if (p.name != null && p.name.startsWith("pod222.ecom_ag.bjmr.bjmr_prd") && p.name.endsWith("number-of-filters.max")) { + log.warn("============"); + log.warn("No metric ID aggregated metric " + p.name); + log.warn(p.toString()); + log.warn("============"); + } continue; } if (!isWithinRetentionPeriod(p, now)) { + if (p.name != null && p.name.startsWith("pod222.ecom_ag.bjmr.bjmr_prd") && p.name.endsWith("number-of-filters.max")) { + log.warn("============"); + log.warn("Outside retention period aggregated metric " + p.name); + log.warn(p + " " + now); + log.warn("============"); + } continue; } if (p.name != null && p.name.startsWith("pod222.ecom_ag.bjmr.bjmr_prd") && p.name.endsWith("number-of-filters.max")) { log.warn("============"); - log.warn("Received aggregated metric " + p.name); + log.warn("Valid aggregated metric " + p.name); log.warn(p.toString()); log.warn("============"); }