From 2aa565ee6c668f0206ec48e017396a92d7d07f1b Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Tue, 29 Jun 2021 17:53:10 +0200 Subject: [PATCH] added close command for the SparkContext --- .../test/java/eu/dnetlib/doiboost/mag/MAGMappingTest.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dhp-workflows/dhp-doiboost/src/test/java/eu/dnetlib/doiboost/mag/MAGMappingTest.scala b/dhp-workflows/dhp-doiboost/src/test/java/eu/dnetlib/doiboost/mag/MAGMappingTest.scala index ff08a3b7d..784f59748 100644 --- a/dhp-workflows/dhp-doiboost/src/test/java/eu/dnetlib/doiboost/mag/MAGMappingTest.scala +++ b/dhp-workflows/dhp-doiboost/src/test/java/eu/dnetlib/doiboost/mag/MAGMappingTest.scala @@ -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))) }