andi/perfdb
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Activity

skip invalid entries

Browse Source
This commit is contained in:
Andreas Huber
2017-09-24 17:21:20 +02:00
parent a7cd918fc6
commit e0655f66fa
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pdb-ui/src/main/java/org/lucares/pdbui/TcpIngestor.java
View File

@@ -116,6 +116,8 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
public Optional<Entry> createEntry(final Map<String, Object> map) { public Optional<Entry> createEntry(final Map<String, Object> map) {
try { try {
if (map.containsKey("duration")
&& map.containsKey("@timestamp")) {
final OffsetDateTime date = getDate(map); final OffsetDateTime date = getDate(map);
final long duration = (int) map.get("duration"); final long duration = (int) map.get("duration");
@@ -123,8 +125,12 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
final Entry entry = new Entry(date, duration, tags); final Entry entry = new Entry(date, duration, tags);
return Optional.of(entry); return Optional.of(entry);
} else {
LOGGER.info("Skipping invalid entry: " + map);
return Optional.empty();
}
} catch (final Exception e) { } catch (final Exception e) {
LOGGER.error("Failed to create entry.", e); LOGGER.error("Failed to create entry from map: " + map, e);
return Optional.empty(); return Optional.empty();
} }
} }