Merge remote-tracking branch 'origin/MET-6417-out-of-memory-issues-cause-by-metis-validator-service-in-flink-po-c' into develop

Author: marcin-rp

validation/src/main/java/eu/europeana/processing/validation/processor/ValidationOperator.java

@@ -110,13 +110,20 @@ private String reorderFileContent(ExecutionRecordResult executionRecordResult) t
     }
 
     private void validateFile(ExecutionRecordResult executionRecordResult, String sortedDocument) {
-        ValidationResult result =
-            validationService.singleValidation(
-                schema,
-                rootFileLocation,
-                schematronFileLocation,
-                sortedDocument
-            );
+        ValidationResult result;
+        ClassLoader original = Thread.currentThread().getContextClassLoader();
+        try {
+            Thread.currentThread().setContextClassLoader(ValidationExecutionService.class.getClassLoader());
+            result =
+                    validationService.singleValidation(
+                            schema,
+                            rootFileLocation,
+                            schematronFileLocation,
+                            sortedDocument
+                    );
+        } finally {
+            Thread.currentThread().setContextClassLoader(original);
+        }
         if (result.isSuccess()) {
             LOGGER.debug("Validation Success for datasetId {}, recordId {}", executionRecordResult.getExecutionRecord().getExecutionRecordKey().getDatasetId(),
                     executionRecordResult.getRecordId());