-

dhp-workflows/dhp-graph-mapper/src/main/resources/eu/dnetlib/dhp/oa/graph/dump_whole/input_organization_parameters.json

@@ -23,6 +23,12 @@
 		"paramLongName": "isSparkSessionManaged",
 		"paramDescription": "true if the spark session is managed, false otherwise",
 		"paramRequired": false
+	},
+	{
+		"paramName":"cmp",
+		"paramLongName":"communityMapPath",
+		"paramDescription": "the path to the serialization of the community map",
+		"paramRequired": true
 	}
 ]
 

dhp-workflows/dhp-graph-mapper/src/main/resources/eu/dnetlib/dhp/oa/graph/dump_whole/oozie_app/workflow.xml

@@ -406,6 +406,7 @@
             <arg>--sourcePath</arg><arg>${sourcePath}/relation</arg>
             <arg>--outputPath</arg><arg>${workingDir}/relation/contextOrg</arg>
             <arg>--organizationCommunityMap</arg><arg>${organizationCommunityMap}</arg>
+            <arg>--communityMapPath</arg><arg>${workingDir}/communityMap</arg>
         </spark>
         <ok to="join_context"/>
         <error to="Kill"/>
@@ -547,6 +548,7 @@
             </spark-opts>
             <arg>--sourcePath</arg><arg>${workingDir}</arg>
             <arg>--outputPath</arg><arg>${workingDir}/collect</arg>
+            <arg>--resultAggregation</arg><arg>${resultAggregation}</arg>
         </spark>
         <ok to="make_archive"/>
         <error to="Kill"/>
@@ -558,9 +560,8 @@
             <arg>--hdfsPath</arg><arg>${outputPath}</arg>
             <arg>--nameNode</arg><arg>${nameNode}</arg>
             <arg>--sourcePath</arg><arg>${workingDir}/collect</arg>
-            <arg>--resultAggregation</arg><arg>${resultAggregation}</arg>
         </java>
-        <ok to="send_zenodo"/>
+        <ok to="End"/>
         <error to="Kill"/>
     </action>