diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/FileStatusPersistenceService.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/FileStatusPersistenceService.java index 8df7c94fc..68b4aeb0a 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/FileStatusPersistenceService.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/persistence/FileStatusPersistenceService.java @@ -166,14 +166,20 @@ public class FileStatusPersistenceService { @Transactional public void updateStatusErrorInfo(String fileId, FileErrorInfo fileErrorInfo) { + if (fileErrorInfo == null) { fileRepository.updateStatusErrorInfo(fileId, null, null, null, null); } else { - fileRepository.updateStatusErrorInfo(fileId, fileErrorInfo.getCause(), fileErrorInfo.getQueue(), fileErrorInfo.getService(), fileErrorInfo.getTimestamp()); + fileRepository.updateStatusErrorInfo(fileId, + fileErrorInfo.getCause().substring(0, Math.min(fileErrorInfo.getCause().length(), 255)), + fileErrorInfo.getQueue(), + fileErrorInfo.getService(), + fileErrorInfo.getTimestamp()); } } + @Transactional public void updateProcessingStatus(String fileId, ProcessingStatus processingStatus) {