diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob.java index d2b50791dd..7cb3bd839f 100644 --- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob.java +++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob.java @@ -88,7 +88,7 @@ public class SparkCountryPropagationJob { final JavaRDD toupdateresultdataset = propagateOnResult(spark, "openaire.dataset"); final JavaRDD toupdateresultother = propagateOnResult(spark, "openaire.otherresearchproduct"); final JavaRDD toupdateresultpublication = propagateOnResult(spark, "openaire.publication"); - + writeUpdates(toupdateresultsoftware, toupdateresultdataset, toupdateresultother, toupdateresultpublication, outputPath); createUpdateForSoftwareDataset(toupdateresultsoftware, inputPath, spark)