From 58f8606cd33cbf36733ca7fb9990893aed5f1daa Mon Sep 17 00:00:00 2001 From: Andreas Huber Date: Thu, 13 Apr 2017 20:12:00 +0200 Subject: [PATCH] use special logger for insertion metrics This allows us to enable/disable metric logging without having to log other stuff. --- pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java | 2 +- .../java/org/lucares/performance/db/PerformanceDb.java | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java index 910ae25..bc46b91 100644 --- a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java +++ b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java @@ -102,7 +102,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean { } if (entry.isPresent()) { - LOGGER.trace("adding entry to queue: {}", entry); + LOGGER.debug("adding entry to queue: {}", entry); queue.put(entry.get()); } diff --git a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java index f548f7f..d14e43a 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java @@ -32,6 +32,7 @@ import com.fasterxml.jackson.databind.ObjectMapper; public class PerformanceDb implements AutoCloseable, CollectionUtils { private final static Logger LOGGER = LoggerFactory.getLogger(PerformanceDb.class); + private final static Logger METRICS_LOGGER = LoggerFactory.getLogger("org.lucares.metrics.ingestion.block"); private final TagsToFile tagsToFile; @@ -65,7 +66,7 @@ public class PerformanceDb implements AutoCloseable, CollectionUtils { public void put(final BlockingIterator entries) throws WriteException { - final int blocksize = 10000; + final int blocksize = 100000; long count = 0; try { @@ -90,8 +91,8 @@ public class PerformanceDb implements AutoCloseable, CollectionUtils { if (count % blocksize == 0) { final long end = System.currentTimeMillis(); final long duration = end - start; - LOGGER.debug("inserting the last " + blocksize + " took " + duration + " ms; total entries: " - + count / 1_000_000.0 + " million"); + METRICS_LOGGER.debug("inserting the last " + blocksize + " took " + duration + + " ms; total entries: " + count / 1_000_000.0 + " million"); start = System.currentTimeMillis(); }