Skip to content

Commit f1366f0

Browse files
committed
Check for empty project ID after replacement.
1 parent d08a759 commit f1366f0

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/org/radarcns/RestructureAvroRecords.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -289,11 +289,14 @@ private void writeRecord(GenericRecord record, String topicName, FileCacheStore
289289

290290
String projectId;
291291

292-
if(keyField.get("projectId") == null) {
292+
if (keyField.get("projectId") == null) {
293293
projectId = "unknown-project";
294294
} else {
295295
// Clean Project id for use in final pathname
296296
projectId = keyField.get("projectId").toString().replaceAll("[^a-zA-Z0-9_-]+", "");
297+
if (projectId.isEmpty()) {
298+
projectId = "empty-project-id";
299+
}
297300
}
298301

299302
// Clean user id and create final output pathname

0 commit comments

Comments
 (0)