You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2017/05/31 16:58:06 UTC
bahir git commit: [BAHIR-120] Akka SQL Streaming build fails with
Apache Spark 2.1.1
Repository: bahir
Updated Branches:
refs/heads/master 86ded930e -> 2a4307657
[BAHIR-120] Akka SQL Streaming build fails with Apache Spark 2.1.1
Closes #44.
Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/2a430765
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/2a430765
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/2a430765
Branch: refs/heads/master
Commit: 2a43076579dd247db4afa01e2dc0d1176c3eb4a1
Parents: 86ded93
Author: Subhobrata Dey <sb...@gmail.com>
Authored: Tue May 30 23:43:39 2017 -0700
Committer: Luciano Resende <lr...@apache.org>
Committed: Wed May 31 09:57:15 2017 -0700
----------------------------------------------------------------------
.../apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bahir/blob/2a430765/sql-streaming-akka/src/test/scala/org/apache/bahir/sql/streaming/akka/AkkaStreamSourceSuite.scala
----------------------------------------------------------------------
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 a04dc66..5e9b86e 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 {