From 9963fd6d293d5b8e7d162ebea01d443f91d5e8af Mon Sep 17 00:00:00 2001 From: Sandro La Bruzzo Date: Wed, 28 Jun 2023 13:36:05 +0200 Subject: [PATCH] updated log to add subentity --- .../main/java/eu/dnetlib/dhp/oa/dedup/SparkCreateSimRels.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCreateSimRels.java b/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCreateSimRels.java index bf8906bea..ca6398e8a 100644 --- a/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCreateSimRels.java +++ b/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCreateSimRels.java @@ -117,7 +117,7 @@ public class SparkCreateSimRels extends AbstractSparkAction { saveParquet(simRels, outputPath, SaveMode.Overwrite); final long end = System.currentTimeMillis(); if (StringUtils.isNotBlank(dfLogPath)) { - final DedupLogModel model = new DedupLogModel(runTag, dedupConf.toString(), entity, start, end, + final DedupLogModel model = new DedupLogModel(runTag, dedupConf.toString(), subEntity, start, end, end - start); new DedupLogWriter(dfLogPath).appendLog(model, spark);