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);