diff --git
a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingSymmetricHashJoinHelperSuite.scala
b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingSymmetricHashJoinHelperSuite.scala
index 69b7154895341..56378085be0be 100644
---
a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingSymmetricHashJoinHelperSuite.scala
+++
b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingSymmetricHashJoinHelperSuite.scala
@@ -35,8 +35,14 @@ class StreamingSymmetricHashJoinHelperSuite extends
StreamTest {
val rightColC = new Column(rightAttributeC)
val rightColD = new Column(rightAttributeD)
- val left = new LocalTableScanExec(Seq(leftAttributeA, leftAttributeB), Seq())
- val right = new LocalTableScanExec(Seq(rightAttributeC, rightAttributeD),
Seq())
+ var left: LocalTableScanExec = _
+ var right: LocalTableScanExec = _
+
+ protected override def beforeAll(): Unit = {
+ super.beforeAll()
+ left = new LocalTableScanExec(Seq(leftAttributeA, leftAttributeB), Seq())
+ right = new LocalTableScanExec(Seq(rightAttributeC, rightAttributeD),
Seq())
+ }
test("empty") {
val split = JoinConditionSplitPredicates(None, left, right)
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
