changed the test to check for the new ignorecase option

This commit is contained in:
Miriam Baglioni 2020-04-27 12:31:46 +02:00
parent 986c97348d
commit 7a59324ccf
1 changed files with 2 additions and 2 deletions

View File

@ -795,9 +795,9 @@ public class BulkTagJobTest {
org.apache.spark.sql.Dataset<Row> idExplodeCommunity = spark.sql(query); org.apache.spark.sql.Dataset<Row> idExplodeCommunity = spark.sql(query);
idExplodeCommunity.show(false); idExplodeCommunity.show(false);
Assertions.assertEquals(2, idExplodeCommunity.count()); Assertions.assertEquals(3, idExplodeCommunity.count());
Assertions.assertEquals( Assertions.assertEquals(
2, idExplodeCommunity.filter("provenance = 'community:datasource'").count()); 3, idExplodeCommunity.filter("provenance = 'community:datasource'").count());
} }
} }