From 47c7122773cde57c6e81bd3fbdc679fa9e768a1a Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Fri, 17 Jul 2020 12:56:35 +0200
Subject: [PATCH] changed priority from beta to production

---
 .../eu/dnetlib/dhp/oa/graph/merge/MergeGraphSparkJob.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/merge/MergeGraphSparkJob.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/merge/MergeGraphSparkJob.java
index 8baa469bf..67068e072 100644
--- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/merge/MergeGraphSparkJob.java
+++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/merge/MergeGraphSparkJob.java
@@ -96,11 +96,11 @@ public class MergeGraphSparkJob {
 			.map((MapFunction<Tuple2<Tuple2<String, P>, Tuple2<String, B>>, P>) value -> {
 				Optional<P> p = Optional.ofNullable(value._1()).map(Tuple2::_2);
 				Optional<B> b = Optional.ofNullable(value._2()).map(Tuple2::_2);
-				if (p.isPresent() & !b.isPresent()) {
-					return p.get();
+				if (b.isPresent() & !p.isPresent()) {
+					return (P)b.get();
 				}
-				if (b.isPresent()) {
-					return (P) b.get();
+				if (p.isPresent()) {
+					return p.get();
 				}
 				return null;
 			}, Encoders.bean(p_clazz))