From 81717528e934e31f25aa1ec54d52495451b6cea0 Mon Sep 17 00:00:00 2001 From: Subhobrata Dey Date: Tue, 30 May 2017 23:43:39 -0700 Subject: [PATCH] [BAHIR-120] Akka SQL Streaming build fails with Apache Spark 2.1.1 --- .../bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/sql-streaming-akka/src/test/scala/org/apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala b/sql-streaming-akka/src/test/scala/org/apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala index a04dc66c..5e9b86e9 100644 --- a/sql-streaming-akka/src/test/scala/org/apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala +++ b/sql-streaming-akka/src/test/scala/org/apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala @@ -40,11 +40,10 @@ class AkkaStreamSourceSuite extends SparkFunSuite with BeforeAndAfter { private val conf = new SparkConf().setMaster("local[4]").setAppName("AkkaStreamSourceSuite") protected val spark = SparkSession.builder().config(conf).getOrCreate() - akkaTestUtils = new AkkaTestUtils - akkaTestUtils.setup() - before { tempDir.mkdirs() + akkaTestUtils = new AkkaTestUtils + akkaTestUtils.setup() } after {