diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java index bb4dfe4298..9fbe7a8144 100644 --- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java +++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java @@ -64,7 +64,7 @@ public class PrepareResultInstRepoAssociation { "where datainfo.deletedbyinference = false " + "and relClass = '" + RELATION_RESULT_ORGANIZATION_REL_CLASS +"' " + "group by source"; - + spark.sql(query) .as(Encoders.bean(ResultOrganizationSet.class))