minor

SANSA-Stack · Feb 26, 2021 · 2a6c8cc · 2a6c8cc
1 parent 4c2b0fe
commit 2a6c8cc
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/.../src/test/scala/net/sansa_stack/query/spark/compliance/SPARQL11TestSuiteRunnerSpark.scala b/.../src/test/scala/net/sansa_stack/query/spark/compliance/SPARQL11TestSuiteRunnerSpark.scala
@@ -83,8 +83,12 @@ abstract class SPARQL11TestSuiteRunnerSpark
 
     // we drop the Spark database to remove all tables from previous loaded data
     spark.sql(s"DROP DATABASE IF EXISTS $db")
-    spark.catalog.listTables().foreach(t => spark.catalog.dropTempView(s"${sqlEscaper.forSchemaName().encode(t.name)}"))
-    spark.catalog.listTables(db).foreach(t => spark.catalog.dropTempView(s"${sqlEscaper.forSchemaName().encode(t.name)}"))
+    spark.catalog.listTables().foreach(t => {
+      val b = spark.catalog.dropTempView(s"${sqlEscaper.forSchemaName().encode(t.name)}")
+    })
+    spark.catalog.listTables(db).foreach(t => {
+      val b = spark.catalog.dropTempView(s"${sqlEscaper.forSchemaName().encode(t.name)}")
+    })
 
     // distribute on Spark
     val triplesRDD = spark.sparkContext.parallelize(data.getGraph.find().toList.asScala)