Skip to content

Commit a8bb858

Browse files
fix[backend](initial-setup): improved error handling on failed to insert filter
1 parent 717bcc4 commit a8bb858

1 file changed

Lines changed: 13 additions & 2 deletions

File tree

backend/src/main/java/com/park/utmstack/service/DefinitionSyncService.java

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,12 @@ private Set<Long> syncFilters() {
114114
log.info("Updating existing filter for module: {}", moduleName);
115115
filter.setLogstashFilter(content);
116116
filter.setUpdatedAt(Instant.now());
117-
filterService.save(filter);
117+
try{
118+
filterService.save(filter);
119+
}
120+
catch (Exception e) {
121+
log.error("Error updating filter on file {}: {}", path, e.getMessage());
122+
}
118123
}
119124
} else {
120125
UtmLogstashFilter filter = new UtmLogstashFilter();
@@ -132,8 +137,14 @@ private Set<Long> syncFilters() {
132137
filter.setDatatype(dataTypeEntity.get());
133138
}
134139

135-
filterService.save(filter);
136140
log.info("Creating filter from file {} for module: {} and dataType {}, filter: {}",path,moduleName, dataTypeStr,filter);
141+
try{
142+
filterService.save(filter);
143+
}
144+
catch (Exception e) {
145+
log.error("Error creating filter on file {}: {}", path, e.getMessage());
146+
}
147+
137148
}
138149
} catch (IOException e) {
139150
log.error("Error reading filter file {}: {}", path, e.getMessage());

0 commit comments

Comments
 (0)