diff --git a/dhp-workflows/dhp-bulktag/src/test/java/eu/dnetlib/dhp/BulkTagJobTest.java b/dhp-workflows/dhp-bulktag/src/test/java/eu/dnetlib/dhp/BulkTagJobTest.java index e20d87280..04c8816df 100644 --- a/dhp-workflows/dhp-bulktag/src/test/java/eu/dnetlib/dhp/BulkTagJobTest.java +++ b/dhp-workflows/dhp-bulktag/src/test/java/eu/dnetlib/dhp/BulkTagJobTest.java @@ -795,9 +795,9 @@ public class BulkTagJobTest { org.apache.spark.sql.Dataset idExplodeCommunity = spark.sql(query); idExplodeCommunity.show(false); - Assertions.assertEquals(2, idExplodeCommunity.count()); + Assertions.assertEquals(3, idExplodeCommunity.count()); Assertions.assertEquals( - 2, idExplodeCommunity.filter("provenance = 'community:datasource'").count()); + 3, idExplodeCommunity.filter("provenance = 'community:datasource'").count()); } }