diff --git a/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/input_countrypropagation_parameters.json b/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/input_countrypropagation_parameters.json
index 7545f30c4..912c88743 100644
--- a/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/input_countrypropagation_parameters.json
+++ b/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/input_countrypropagation_parameters.json
@@ -11,17 +11,11 @@
"paramDescription": "the hive metastore uris",
"paramRequired": true
},
- {
- "paramName":"wu",
- "paramLongName":"writeUpdate",
- "paramDescription": "true if the update must be written. No double check if information is already present",
- "paramRequired": true
- },
{
"paramName":"sg",
"paramLongName":"saveGraph",
"paramDescription": "true if the new version of the graph must be saved",
- "paramRequired": true
+ "paramRequired": false
},
{
"paramName":"tn",
diff --git a/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/oozie_app/workflow.xml b/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/oozie_app/workflow.xml
index 3a8aa949a..bd2473308 100644
--- a/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/oozie_app/workflow.xml
+++ b/dhp-workflows/dhp-propagation/src/main/resources/eu/dnetlib/dhp/countrypropagation/oozie_app/workflow.xml
@@ -28,10 +28,6 @@
sparkExecutorNumber
number of executors used
-
- writeUpdate
- writes the information found for the update. No double check done if the information is already present
-
saveGraph
writes new version of the graph after the propagation step
@@ -46,8 +42,12 @@
-
+
+
+
+
+
@@ -58,7 +58,7 @@
${jobTracker}
${nameNode}
${nameNode}/${sourcePath}/relation
- ${nameNode}/${workingDir}/country_propagation/relation
+ ${nameNode}/${workingDir}/relation
@@ -115,10 +115,9 @@
--sourcePath${sourcePath}/publication
--hive_metastore_uris${hive_metastore_uris}
- --writeUpdate${writeUpdate}
--saveGraph${saveGraph}
--resultTableNameeu.dnetlib.dhp.schema.oaf.Publication
- --outputPath${workingDir}/country_propagation/publication
+ --outputPath${workingDir}/publication
--preparedInfoPath${workingDir}/preparedInfo
@@ -145,10 +144,9 @@
--sourcePath${sourcePath}/dataset
--hive_metastore_uris${hive_metastore_uris}
- --writeUpdate${writeUpdate}
--saveGraph${saveGraph}
--resultTableNameeu.dnetlib.dhp.schema.oaf.Dataset
- --outputPath${workingDir}/country_propagation/dataset
+ --outputPath${workingDir}/dataset
--preparedInfoPath${workingDir}/preparedInfo
@@ -175,10 +173,9 @@
--sourcePath${sourcePath}/otherresearchproduct
--hive_metastore_uris${hive_metastore_uris}
- --writeUpdate${writeUpdate}
--saveGraph${saveGraph}
--resultTableNameeu.dnetlib.dhp.schema.oaf.OtherResearchProduct
- --outputPath${workingDir}/country_propagation/otherresearchproduct
+ --outputPath${workingDir}/otherresearchproduct
--preparedInfoPath${workingDir}/preparedInfo
@@ -205,10 +202,9 @@
--sourcePath${sourcePath}/software
--hive_metastore_uris${hive_metastore_uris}
- --writeUpdate${writeUpdate}
--saveGraph${saveGraph}
--resultTableNameeu.dnetlib.dhp.schema.oaf.Software
- --outputPath${workingDir}/country_propagation/software
+ --outputPath${workingDir}/software
--preparedInfoPath${workingDir}/preparedInfo