added close command for the SparkContext

This commit is contained in:
Miriam Baglioni 2021-06-29 17:53:10 +02:00
parent d5d21254a2
commit 2aa565ee6c
1 changed files with 3 additions and 3 deletions

View File

@ -87,7 +87,7 @@ class MAGMappingTest {
assertTrue(ret.count == 10)
ret.take(10).foreach(mp => assertTrue(mp.Doi.equals(mp.Doi.toLowerCase())))
spark.close()
}
@Test
@ -113,8 +113,8 @@ class MAGMappingTest {
val ret :Dataset[MagPapers] = SparkProcessMAG.getDistinctResults(magPapers)
assertTrue(ret.count == 8)
ret.take(8).foreach(mp => assertTrue(mp.Doi.equals(mp.Doi.toLowerCase())))
ret.take(8).foreach(mp => println(write(mp)))
spark.close()
//ret.take(8).foreach(mp => println(write(mp)))
}