Lampros Smyrnaios
ed7bf09f9b
- Replace all "json" usages, with "gson" ones, in order to remove the "org.json:json" dependency.
...
- Add an extra check to verify that the remote parquet directories are directories indeed.
- Set new version.
2024-06-06 14:40:39 +03:00
Lampros Smyrnaios
edf064616a
Improve error-handling in "BulkImportReport.getJsonReport()" and "FileUtils.writeToFile()".
2024-05-30 11:52:04 +03:00
Lampros Smyrnaios
d7697ef3f8
- Tighten the thread-safety protection on the "BulkImportReport.getJsonReport()" method.
...
- Update dependencies.
- Code polishing.
2024-05-27 10:40:05 +03:00
Lampros Smyrnaios
b6ad2af48b
- Reduce occupying space at any given time, by deleting the archives right after decompression and files-extraction.
...
- Code refactoring.
2024-05-22 12:11:39 +03:00
Lampros Smyrnaios
e2e7ca72d5
- Fix not allowing the user to use the "shutdownAllWorkersGracefully" endpoint twice.
...
- Code optimization.
- Update dependencies.
2024-05-21 23:43:49 +03:00
Lampros Smyrnaios
39c36f9e66
- Resolve a concurrency issue, by enforcing synchronization on the "BulkImportReport.getJsonReport()" method.
...
- Increase the number of stacktrace-lines to 20, for bulkImport-segment-failures.
- Improve "GenericUtils.getSelectiveStackTrace()".
2024-05-01 01:29:25 +03:00
Lampros Smyrnaios
0d117743c2
- Code-optimization.
...
- Upload the updated gradle-wrapper and set using the latest Gradle version in "installAndRun.sh" script.
2024-04-30 02:13:08 +03:00
Lampros Smyrnaios
64a1b7d4f0
- Comment-out the bucket-deletion process, in order to avoid any accidental deletion, even if it has to be explicitly allowed in the config.
...
- Update dependencies.
2024-04-26 12:54:00 +03:00
Lampros Smyrnaios
e2d43a9af0
Upgrade the "processBulkImportedFilesSegment" code:
...
1) Pre-calculate the file-hashes for all files of the segment and perform a single "getHashLocationsQuery", instead of thousands
2) Write some important events to the bulkImportReport file, as soon as they are added in the list.
2024-04-02 14:35:19 +03:00
Lampros Smyrnaios
bd323ad69a
Avoid a very rare case, where we might get an "IllegalArgumentException" from "Lists.partition()", in case the "sizeOfUrlReports" is <= 3.
2024-03-29 18:12:52 +02:00
Lampros Smyrnaios
08de530f03
Various improvements:
...
- Handle the case when "fileUtils.constructS3FilenameAndUploadToS3()" returns "null", in "processBulkImportedFile()".
- Avoid an "IllegalArgumentException" in "Lists.partition()" when the number of files to bulkImport are fewer than the number of threads available to handle them.
- Include the last directory's "/" divider in the fileDIR group of "FILEPATH_ID_EXTENSION" regex (renamed from "FILENAME_ID_EXTENSION").
- Fix an incomplete log-message.
- Provide the "fileLocation" argument in the "DocFileData" constructor, in "processBulkImportedFile()", even though it's not used after.
2024-03-29 17:23:01 +02:00
Lampros Smyrnaios
1d821ed803
- Prepare version for next release.
...
- Fix typo of not using the "OpenAireID" in the S3 location of bulkImported files. Instead, the "fileNameID" was used, which in aggregation is the OpenAireID, but not in bulk-import.
- Update dependencies.
- Code polishing.
2024-03-28 06:09:28 +02:00
Lampros Smyrnaios
8bc5cc35e2
- Optimize writing to the Bulk-import-report file.
...
- Show the IP of the worker which posts a "workerShutdownReport".
- Code polishing.
2024-03-22 17:50:55 +02:00
Lampros Smyrnaios
b9b29dd51c
Move some code from "FileUtils.getAndUploadFullTexts()" to two separate methods.
2024-03-20 16:53:03 +02:00
Lampros Smyrnaios
56d233d38e
- Move the "FileUtils.mergeParquetFiles()" method to "ParquetFileUtils.mergeParquetFilesOfTable()".
...
- Fix a typo.
2024-03-20 15:25:19 +02:00
Lampros Smyrnaios
9b0818b535
- Add handling for additional/specific exceptions, when checking the "futures".
...
- Move common "ExecutionException" handling-code into its own method: "GenericUtils.getSelectedStackTraceForCausedException()".
- Avoid a double log.
- Code polishing.
2024-03-14 13:59:23 +02:00
Lampros Smyrnaios
f61cae41a1
- Try to get the cause of the exception of the callable-tasks which handle the bulk-import of fileSegments.
...
- Fix not counting the failedSegments when an exception was thrown.
- Code polishing.
2024-03-13 12:15:59 +02:00
Lampros Smyrnaios
8f9786de09
Upgrade the algorithm for finding the previously-found fulltexts, based on their md5hash:
...
- Use a single query with a list of the fileHashes, instead of thousands of singe-md5hash-check queries (run at most 6 in parallel) which require a lot of I/O.
- Avoid checking multiple times the same fileHash, in case it is related with multiple payloads.
- In case of a database-error, avoid completely losing the full-texts of that worker, instead, continue processing the full-texts.
2024-03-13 11:28:37 +02:00
Lampros Smyrnaios
e4540e7f3c
Handle the case when a urlReports-sublist does not have any payloads inside.
2024-03-12 14:25:00 +02:00
Lampros Smyrnaios
e20c5d2146
- Add error-handling for the case when no payloads could be associated with a specific url which should have been in the hashMultiMap in "addUrlReportsByMatchingRecordsFromBacklog".
...
- Fix not cloning the payload, before changing it and adding it in the "prefilledPayloads"-list; instead, an object-reference was used.
2024-03-11 19:48:04 +02:00
Lampros Smyrnaios
1048463ca0
- Improve error-handling in "S3ObjectStore.emptyBucket()".
...
- Change some log-levels.
- Code polishing.
2024-03-11 16:17:32 +02:00
Lampros Smyrnaios
ce3e149a95
Improve the "emptying/deleting" process of the S3-bucket.
2024-03-11 13:34:38 +02:00
Lampros Smyrnaios
43ea64758d
- Improve handling of the case when no fulltexts have been found or none of the found ones were requested from the worker, as they were already retrieved in the past.
...
- Show the number of files with problematic locations (if any of them exist).
- Code polishing.
2024-02-23 12:39:28 +02:00
Lampros Smyrnaios
3563fd6e2a
- Try to get the cause of the exception of the callable-tasks which handle parquet-files.
...
- Update License.
- Update dependencies.
2024-02-07 18:34:28 +02:00
Lampros Smyrnaios
34d7a143e7
Add/improve documentation.
2024-02-01 14:37:29 +02:00
Lampros Smyrnaios
5dadb8ad2f
- Optimize the "DOC_URL_FILTER"-regex, by using a non-capturing group.
...
- Remove an extra "File.separator" from the fulltexts-fullFilePath.
2024-01-19 15:46:23 +02:00
Lampros Smyrnaios
ee1ca8966b
- Avoid continuing to request workerReport-batches when from the 1st batch, the base-directory of that assignments-counter is not found.
...
- Update dependencies.
2024-01-15 12:57:33 +02:00
Lampros Smyrnaios
2e60128084
- Allow to easily change the por used by workers.
...
- Show the number of active background-tasks and bulkImportDirs, which delay the Service's shutdown.
- Update dependencies.
- Code polishing.
2023-12-19 23:31:42 +02:00
Lampros Smyrnaios
d20c9a7d2e
- Show the original exception thrown by the background-job, not the one thrown in the main-thread, which is useless, except from its message.
...
- Reduce the interval for deleting the unhandled assignments to once every 3 days.
- Set the upcoming version.
- Update dependencies.
2023-11-27 18:19:53 +02:00
Lampros Smyrnaios
7f789b8ad0
- If we receive an "UnknownHostException" when uploading to the S3ObjectStore, then skip the current full-texts' batch to leave some time for the network to get unstuck.
...
- Code polishing.
2023-11-22 15:29:18 +02:00
Lampros Smyrnaios
856c62887d
- Make sure the "UTF_8" charset is used, when we get a message from the response-body.
...
- Improve some log-messages.
2023-10-26 11:44:23 +03:00
Lampros Smyrnaios
0c7bf6357b
- Improve performance in "FileUtils.addUrlReportsByMatchingRecordsFromBacklog()".
...
- Make sure we remove the assignments of all "not-successful", old, worker-reports, even for the ones which failed to be renamed to indicate success or failure, or failed to be executed by the background threads (and thus never reached the renaming stage).
2023-10-23 12:21:42 +03:00
Lampros Smyrnaios
a7581335f1
- Improve the "getDataForPayloadPrefillQuery".
...
- Improve some error-messages.
2023-10-21 11:31:31 +03:00
Lampros Smyrnaios
df0ea62a5a
- Handle the case when the "webHDFSBaseUrl" does not use HTTPS.
...
- Improve error-reporting when uploading a file to HDFS.
2023-10-19 11:59:37 +03:00
Lampros Smyrnaios
40729c6295
Move similar code into the new "ParquetFileUtils.getPayloadParquetRecord()" method.
2023-10-17 12:50:51 +03:00
Lampros Smyrnaios
f05eee7569
Improve the names of some methods.
2023-10-16 23:39:43 +03:00
Lampros Smyrnaios
a354da763d
- Improve some log-messages.
...
- Increase app's version.
- Code polishing.
2023-10-06 17:28:54 +03:00
Lampros Smyrnaios
96c11ba4b8
- Add a missing change.
...
- Code optimization and polishing.
- Update dependencies.
2023-10-04 16:17:12 +03:00
Lampros Smyrnaios
7019f7c3c7
Improve aggregation speed, by generating additional "attempt" and "payload" records for the publications which are in the back-log and their url matches to one of the urls of the current payloads.
2023-10-04 15:43:31 +03:00
Lampros Smyrnaios
c9626de120
Handle the case when the "upload-file-to-S3" operation fails with a "ConnectException". In this case, all remaining upload operations for the files of that particular batch or segment, are canceled.
2023-10-04 13:01:13 +03:00
Lampros Smyrnaios
865926fbc3
- Handle the case when some results have been found from the "getAssignmentsQuery", but no data could be extracted from them.
...
- Code polishing.
2023-10-02 15:46:55 +03:00
Lampros Smyrnaios
ede7ca5a89
- Add bulk-import support for non-Authoritative data-sources.
...
- Update Spring Boot.
- Code polishing.
2023-09-26 18:02:48 +03:00
Lampros Smyrnaios
0f5d4dac78
Check and show warning/error message for failed payloads.
2023-09-20 17:38:22 +03:00
Lampros Smyrnaios
903c3e1ffc
Add thread-safety when reading the bulkImportReport-files.
2023-09-15 11:54:32 +03:00
Lampros Smyrnaios
360731ba72
- Improve handling of the "NO_CONTENT" case, in "getAssignments"-endpoint.
...
- Code optimization and polishing.
2023-09-14 13:53:01 +03:00
Lampros Smyrnaios
6891c467d4
- Avoid displaying a warning for the "test" HDFS directory, when the Controller is running in PROD mode.
...
- Add a missing change for the optimization of reading files.
- Update dependencies.
2023-09-13 15:29:30 +03:00
Lampros Smyrnaios
ee2df19ce1
- Allow "pretty-printing" the json response of the "getBulkImportReport" endpoint.
...
- Add useful log-messages for various bulk-import stages and improve the current ones.
- Optimize reading and writing the reports.
2023-09-11 17:24:39 +03:00
Lampros Smyrnaios
1c8f3765ca
- Fix not acquiring the full workerReport when retrying it, with the scheduler.
...
- Improve error-handling in the "inspectWorkerReportsAndTakeAction" process.
- Code polishing.
2023-09-08 14:59:48 +03:00
Lampros Smyrnaios
4014d1eabb
Code polishing.
2023-09-05 15:20:03 +03:00
Lampros Smyrnaios
98516498eb
- Increase app's version.
...
- Code polishing.
2023-09-04 12:46:55 +03:00