diff --git a/dhp-workflows/dhp-aggregation/pom.xml b/dhp-workflows/dhp-aggregation/pom.xml
index dc8e5b20b..b202abccf 100644
--- a/dhp-workflows/dhp-aggregation/pom.xml
+++ b/dhp-workflows/dhp-aggregation/pom.xml
@@ -7,6 +7,37 @@
1.2.4-SNAPSHOT
dhp-aggregation
+
+
+
+
+ net.alchim31.maven
+ scala-maven-plugin
+ 4.0.1
+
+
+ scala-compile-first
+ initialize
+
+ add-source
+ compile
+
+
+
+ scala-test-compile
+ process-test-resources
+
+ testCompile
+
+
+
+
+ ${scala.version}
+
+
+
+
+
@@ -24,12 +55,6 @@
eu.dnetlib.dhp
dhp-common
${project.version}
-
-
- com.sun.xml.bind
- jaxb-core
-
-
diff --git a/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/actionmanager/datacite/oozie_app/workflow.xml b/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/actionmanager/datacite/oozie_app/workflow.xml
index 1851c815f..48c05d56a 100644
--- a/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/actionmanager/datacite/oozie_app/workflow.xml
+++ b/dhp-workflows/dhp-aggregation/src/main/resources/eu/dnetlib/dhp/actionmanager/datacite/oozie_app/workflow.xml
@@ -34,7 +34,7 @@
--conf spark.eventLog.dir=${nameNode}${spark2EventLogDir}
--sourcePath${mainPath}/datacite_dump
- --targetPath${mainPath}/datacite_oaf_production
+ --targetPath${mainPath}/production/datacite_oaf
--isLookupUrl${isLookupUrl}
--masteryarn-cluster
diff --git a/dhp-workflows/dhp-aggregation/src/test/java/eu/dentlib/dhp/aggregation/AbstractVocabularyTest.java b/dhp-workflows/dhp-aggregation/src/test/java/eu/dentlib/dhp/aggregation/AbstractVocabularyTest.java
index 1340af22e..ff507c3d0 100644
--- a/dhp-workflows/dhp-aggregation/src/test/java/eu/dentlib/dhp/aggregation/AbstractVocabularyTest.java
+++ b/dhp-workflows/dhp-aggregation/src/test/java/eu/dentlib/dhp/aggregation/AbstractVocabularyTest.java
@@ -1,4 +1,6 @@
+
package eu.dentlib.dhp.aggregation;
+
import static org.mockito.Mockito.lenient;
import java.io.IOException;
@@ -6,37 +8,43 @@ import java.util.Collections;
import java.util.List;
import java.util.Objects;
-import eu.dnetlib.dhp.oa.graph.raw.common.VocabularyGroup;
import org.apache.commons.io.IOUtils;
import org.mockito.Mock;
+
+import eu.dnetlib.dhp.oa.graph.raw.common.VocabularyGroup;
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
public abstract class AbstractVocabularyTest {
- @Mock
- protected ISLookUpService isLookUpService;
+ @Mock
+ protected ISLookUpService isLookUpService;
- protected VocabularyGroup vocabularies;
+ protected VocabularyGroup vocabularies;
- public void setUpVocabulary() throws ISLookUpException, IOException {
- lenient().when(isLookUpService.quickSearchProfile(VocabularyGroup.VOCABULARIES_XQUERY)).thenReturn(vocs());
+ public void setUpVocabulary() throws ISLookUpException, IOException {
+ lenient().when(isLookUpService.quickSearchProfile(VocabularyGroup.VOCABULARIES_XQUERY)).thenReturn(vocs());
- lenient()
- .when(isLookUpService.quickSearchProfile(VocabularyGroup.VOCABULARY_SYNONYMS_XQUERY))
- .thenReturn(synonyms());
- vocabularies = VocabularyGroup.loadVocsFromIS(isLookUpService);
- }
+ lenient()
+ .when(isLookUpService.quickSearchProfile(VocabularyGroup.VOCABULARY_SYNONYMS_XQUERY))
+ .thenReturn(synonyms());
+ vocabularies = VocabularyGroup.loadVocsFromIS(isLookUpService);
+ }
- private static List vocs() throws IOException {
- return IOUtils
- .readLines(Objects.requireNonNull(AbstractVocabularyTest.class.getResourceAsStream("/eu/dnetlib/dhp/vocabulary/terms.txt")));
- }
-
- private static List synonyms() throws IOException {
- return IOUtils
- .readLines(Objects.requireNonNull(AbstractVocabularyTest.class.getResourceAsStream("/eu/dnetlib/dhp/vocabulary/synonyms.txt")));
- }
+ private static List vocs() throws IOException {
+ return IOUtils
+ .readLines(
+ Objects
+ .requireNonNull(
+ AbstractVocabularyTest.class.getResourceAsStream("/eu/dnetlib/dhp/vocabulary/terms.txt")));
+ }
+ private static List synonyms() throws IOException {
+ return IOUtils
+ .readLines(
+ Objects
+ .requireNonNull(
+ AbstractVocabularyTest.class.getResourceAsStream("/eu/dnetlib/dhp/vocabulary/synonyms.txt")));
+ }
}