diff --git a/dhp-workflows/dhp-patch/src/main/java/eu/dnetlib/dhp/patchrefereed/SparkPrepareResultInstanceList.java b/dhp-workflows/dhp-patch/src/main/java/eu/dnetlib/dhp/patchrefereed/SparkPrepareResultInstanceList.java index f2f866c5a..6f3602936 100644 --- a/dhp-workflows/dhp-patch/src/main/java/eu/dnetlib/dhp/patchrefereed/SparkPrepareResultInstanceList.java +++ b/dhp-workflows/dhp-patch/src/main/java/eu/dnetlib/dhp/patchrefereed/SparkPrepareResultInstanceList.java @@ -20,8 +20,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.fasterxml.jackson.databind.ObjectMapper; - -import eu.dnetlib.dhp.actionmanager.project.SparkAtomicActionJob; import eu.dnetlib.dhp.application.ArgumentApplicationParser; import eu.dnetlib.dhp.common.HdfsSupport; import eu.dnetlib.dhp.schema.oaf.*; @@ -35,7 +33,7 @@ public class SparkPrepareResultInstanceList implements Serializable { String jsonConfiguration = IOUtils .toString( - SparkAtomicActionJob.class + SparkPrepareResultInstanceList.class .getResourceAsStream( "/eu/dnetlib/dhp/patchrefereed/prepare_parameters.json")); @@ -87,7 +85,7 @@ public class SparkPrepareResultInstanceList implements Serializable { Dataset result = readPath(spark, inputPath, resultClazz); - log.info("number of results: {}", result.count()); + //log.info("number of results: {}", result.count()); result.map(r -> { ResultInstance ri = null; List instanceList = Optional