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

fix null pointer exception

Browse Source 
filename were generated without '$', but the parsing code expected
the '$'.
This commit is contained in:
Andreas Huber
2018-03-28 19:34:48 +02:00
parent 9f37243ba3
commit 22c99f8517
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
data-store/src/main/java/org/lucares/pdb/datastore/internal/FolderStorage.java
View File

@@ -45,11 +45,11 @@ public class FolderStorage {
ensureCapacity(); ensureCapacity();
String filename = filenamePrefix + filenameSuffix; String filename = filenamePrefix + "$" + filenameSuffix;
int index = 1; int index = 1;
Path newFile = currentDirectory.resolve(filename); Path newFile = currentDirectory.resolve(filename);
while (Files.exists(newFile)) { while (Files.exists(newFile)) {
filename = filenamePrefix + index++ + filenameSuffix; filename = filenamePrefix + "$" + index++ + filenameSuffix;
newFile = currentDirectory.resolve(filename); newFile = currentDirectory.resolve(filename);
} }
Files.createFile(newFile); Files.createFile(newFile);

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

@@ -142,7 +142,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
default: default:
if (value instanceof String) { if (value instanceof String) {
tags.add(key, (String) value); tags.add(key, (String) value);
} else { } else if (value != null) {
tags.add(key, String.valueOf(value)); tags.add(key, String.valueOf(value));
} }
break; break;

2
performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java
View File

@@ -63,7 +63,7 @@ public class PerformanceDb implements AutoCloseable {
public void put(final BlockingIterator<Entry> entries) throws WriteException { public void put(final BlockingIterator<Entry> entries) throws WriteException {
final Duration timeBetweenSyncs = Duration.ofSeconds(1); final Duration timeBetweenSyncs = Duration.ofSeconds(10);
long count = 0; long count = 0;
long insertionsSinceLastSync = 0; long insertionsSinceLastSync = 0;