diff --git a/dhp-workflows/dhp-enrichment/src/main/resources/eu/dnetlib/dhp/resulttocommunityfromsemrel/oozie_app/workflow.xml b/dhp-workflows/dhp-enrichment/src/main/resources/eu/dnetlib/dhp/resulttocommunityfromsemrel/oozie_app/workflow.xml
index 81b51443c..58d5bb26d 100644
--- a/dhp-workflows/dhp-enrichment/src/main/resources/eu/dnetlib/dhp/resulttocommunityfromsemrel/oozie_app/workflow.xml
+++ b/dhp-workflows/dhp-enrichment/src/main/resources/eu/dnetlib/dhp/resulttocommunityfromsemrel/oozie_app/workflow.xml
@@ -260,6 +260,7 @@
--conf spark.eventLog.dir=${nameNode}${spark2EventLogDir}
--conf spark.dynamicAllocation.enabled=true
--conf spark.dynamicAllocation.maxExecutors=${spark2MaxExecutors}
+ --conf spark.sql.shuffle.partitions=10000
--preparedInfoPath${workingDir}/preparedInfo/mergedCommunityAssoc
--sourcePath${sourcePath}/publication
@@ -289,6 +290,7 @@
--conf spark.eventLog.dir=${nameNode}${spark2EventLogDir}
--conf spark.dynamicAllocation.enabled=true
--conf spark.dynamicAllocation.maxExecutors=${spark2MaxExecutors}
+ --conf spark.sql.shuffle.partitions=5000
--preparedInfoPath${workingDir}/preparedInfo/mergedCommunityAssoc
--sourcePath${sourcePath}/dataset
@@ -318,6 +320,7 @@
--conf spark.eventLog.dir=${nameNode}${spark2EventLogDir}
--conf spark.dynamicAllocation.enabled=true
--conf spark.dynamicAllocation.maxExecutors=${spark2MaxExecutors}
+ --conf spark.sql.shuffle.partitions=2000
--preparedInfoPath${workingDir}/preparedInfo/mergedCommunityAssoc
--sourcePath${sourcePath}/otherresearchproduct
@@ -347,6 +350,7 @@
--conf spark.eventLog.dir=${nameNode}${spark2EventLogDir}
--conf spark.dynamicAllocation.enabled=true
--conf spark.dynamicAllocation.maxExecutors=${spark2MaxExecutors}
+ --conf spark.sql.shuffle.partitions=1000
--preparedInfoPath${workingDir}/preparedInfo/mergedCommunityAssoc
--sourcePath${sourcePath}/software