From 9b4c0d4b3a13f33cf3142c222e3fef93ebcf0f69 Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Fri, 8 May 2020 11:51:45 +0200
Subject: [PATCH] -

---
 .../main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/dhp-workflows/dhp-bulktag/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java b/dhp-workflows/dhp-bulktag/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java
index a6662b9fc..90a99926e 100644
--- a/dhp-workflows/dhp-bulktag/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java
+++ b/dhp-workflows/dhp-bulktag/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java
@@ -97,10 +97,11 @@ public class SparkBulkTagJob {
 
 		ResultTagger resultTagger = new ResultTagger();
 		readPath(spark, inputPath, resultClazz)
-			.map((MapFunction<R, R>) value -> resultTagger
+			.map(
+				(MapFunction<R, R>) value -> resultTagger
 					.enrichContextCriteria(
-							value, communityConfiguration, protoMappingParams),
-					Encoders.bean(resultClazz))
+						value, communityConfiguration, protoMappingParams),
+				Encoders.bean(resultClazz))
 			.write()
 			.mode(SaveMode.Overwrite)
 			.option("compression", "gzip")