Merge branch 'stable_ids' into deduptesting

relations for openorgs: not it choose only one master
2020-11-05 15:52:57 +01:00 · 2020-11-05 15:48:42 +01:00
1 changed files with 4 additions and 5 deletions
--- a/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkPrepareOrgRels.java
+++ b/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkPrepareOrgRels.java
@ -128,12 +128,11 @@ public class SparkPrepareOrgRels extends AbstractSparkAction {
 						List<String> ids = sortIds(l);
 						List<Tuple3<String, String, String>> rels = new ArrayList<>();

-						for (String source : ids) {
-							if (source.contains("openorgs____") || ids.indexOf(source) == 0)
+						String source = ids.get(0);
 						for (String target : ids) {
 							rels.add(new Tuple3<>(source, target, groupId));
 						}
-						}
+
 						return rels.iterator();
 					})
 					.rdd(),
Author	SHA1	Message	Date
miconis	3f2d3253e4	Merge branch 'stable_ids' into deduptesting	2020-11-05 15:52:57 +01:00
miconis	1699d41d39	relations for openorgs: not it choose only one master	2020-11-05 15:48:42 +01:00