Skip to content

Commit 4d36071

Browse files
committed
Fix StreamingJoinSuite
1 parent 0d45567 commit 4d36071

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ import org.apache.spark.sql.{DataFrame, Row, SparkSession}
3131
import org.apache.spark.sql.execution.streaming.{MemoryStream, StatefulOperatorStateInfo, StreamingSymmetricHashJoinExec, StreamingSymmetricHashJoinHelper}
3232
import org.apache.spark.sql.execution.streaming.state.{StateStore, StateStoreProviderId}
3333
import org.apache.spark.sql.functions._
34+
import org.apache.spark.sql.internal.SQLConf
3435
import org.apache.spark.util.Utils
3536

3637
abstract class StreamingJoinSuite
@@ -47,6 +48,10 @@ abstract class StreamingJoinSuite
4748
StateStore.stop()
4849
}
4950

51+
override protected def sparkConf = super.sparkConf
52+
// TODO(SPARK-35095): Use ANSI intervals in streaming join tests
53+
.set(SQLConf.LEGACY_INTERVAL_ENABLED, true)
54+
5055
protected def setupStream(prefix: String, multiplier: Int): (MemoryStream[Int], DataFrame) = {
5156
val input = MemoryStream[Int]
5257
val df = input.toDF

0 commit comments

Comments
 (0)