diff --git a/src/main/java/eu/openaire/urls_controller/services/UrlsServiceImpl.java b/src/main/java/eu/openaire/urls_controller/services/UrlsServiceImpl.java index b5844db..813e10e 100644 --- a/src/main/java/eu/openaire/urls_controller/services/UrlsServiceImpl.java +++ b/src/main/java/eu/openaire/urls_controller/services/UrlsServiceImpl.java @@ -288,6 +288,9 @@ public class UrlsServiceImpl implements UrlsService { FileUtils.UploadFullTextsResponse uploadFullTextsResponse = fileUtils.getAndUploadFullTexts(urlReports, sizeOfUrlReports, curReportAssignmentsCounter, curWorkerId); if ( uploadFullTextsResponse == null ) { // Nothing to post to the Worker, since we do not have the worker's info. + // Rename the worker-report-file to indicate its "failure", so that the scheduler can pick it up and retry processing it. + String workerReportBaseName = this.workerReportsDirPath + File.separator + curWorkerId + File.separator + curWorkerId + "_assignments_" + curReportAssignmentsCounter + "_report"; + getRenamedWorkerReport(workerReportBaseName, new File(workerReportBaseName + ".json"), "No info was found for worker: " + curWorkerId); // It may return null. return false; } else if ( uploadFullTextsResponse == FileUtils.UploadFullTextsResponse.databaseError ) { postReportResultToWorker(curWorkerId, curReportAssignmentsCounter, "Problem with the Impala-database!");