Added assertion in test
This commit is contained in:
parent
9567c13bc3
commit
9097e71853
|
@ -1564,7 +1564,8 @@ public class BulkTagJobTest {
|
|||
|
||||
org.apache.spark.sql.Dataset<Row> idExplodeCommunity = spark.sql(query);
|
||||
|
||||
idExplodeCommunity.show(false);
|
||||
Assertions.assertEquals(3, idExplodeCommunity.filter("community = 'dth'").count());
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue