From e0655f66fad6abb72b1853b00f647117142e0505 Mon Sep 17 00:00:00 2001 From: Andreas Huber Date: Sun, 24 Sep 2017 17:21:20 +0200 Subject: [PATCH] skip invalid entries --- .../java/org/lucares/pdbui/TcpIngestor.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 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 467243f..b8db164 100644 --- a/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java +++ b/pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java @@ -116,15 +116,21 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean { public Optional createEntry(final Map map) { try { - final OffsetDateTime date = getDate(map); - final long duration = (int) map.get("duration"); + if (map.containsKey("duration") + && map.containsKey("@timestamp")) { + final OffsetDateTime date = getDate(map); + final long duration = (int) map.get("duration"); - final Tags tags = createTags(map); + final Tags tags = createTags(map); - final Entry entry = new Entry(date, duration, tags); - return Optional.of(entry); + final Entry entry = new Entry(date, duration, tags); + return Optional.of(entry); + } else { + LOGGER.info("Skipping invalid entry: " + map); + return Optional.empty(); + } } catch (final Exception e) { - LOGGER.error("Failed to create entry.", e); + LOGGER.error("Failed to create entry from map: " + map, e); return Optional.empty(); } }