From 32b0c27217e29e0f9a2aa57d63d4dbec2376a0b6 Mon Sep 17 00:00:00 2001 From: Miriam Baglioni Date: Wed, 9 Jun 2021 18:36:11 +0200 Subject: [PATCH] Aggiornare 'dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java' fix in SQL query: while writing the blacklist constraint it used d.id to indicate the datasource id, but no alias for the datasource was defined. So I removed the alias --- .../PrepareResultInstRepoAssociation.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java index a41399627..3cf36e572 100644 --- a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java +++ b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/PrepareResultInstRepoAssociation.java @@ -93,9 +93,9 @@ public class PrepareResultInstRepoAssociation { SparkSession spark, String datasourceOrganizationPath, List blacklist) { String blacklisted = ""; if (blacklist.size() > 0) { - blacklisted = " AND d.id != '" + blacklist.get(0) + "'"; + blacklisted = " AND id != '" + blacklist.get(0) + "'"; for (int i = 1; i < blacklist.size(); i++) { - blacklisted += " AND d.id != '" + blacklist.get(i) + "'"; + blacklisted += " AND id != '" + blacklist.get(i) + "'"; } }