From 9c9a9562ae31f21cfcc20fafd06455f86bd2492f Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Tue, 2 Apr 2024 16:56:37 +0200
Subject: [PATCH] [UsageCount] fixed error

---
 .../dhp/actionmanager/usagestats/SparkAtomicActionUsageJob.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/usagestats/SparkAtomicActionUsageJob.java b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/usagestats/SparkAtomicActionUsageJob.java
index d74b55475..1d5b35cff 100644
--- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/usagestats/SparkAtomicActionUsageJob.java
+++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/usagestats/SparkAtomicActionUsageJob.java
@@ -111,12 +111,12 @@ public class SparkAtomicActionUsageJob implements Serializable {
 		resultModel
 			.joinWith(datasource, resultModel.col("datasourceId").equalTo(datasource.col("id")), "left")
 			.map((MapFunction<Tuple2<UsageStatsResultModel, Datasource>, UsageStatsResultModel>) t2 -> {
+				UsageStatsResultModel usrm = t2._1();
 				if(Optional.ofNullable(t2._2()).isPresent())
 					usrm.setDatasourceId(usrm.getDatasourceId() + "||" + t2._2().getOfficialname().getValue());
 				else
 					usrm.setDatasourceId(usrm.getDatasourceId() + "||NO_MATCH_FOUND");
 				return usrm;
-				return usrm;
 			}, Encoders.bean(UsageStatsResultModel.class))
 			.write()
 			.mode(SaveMode.Overwrite)