We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1c011ab commit fb63d7eCopy full SHA for fb63d7e
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala
@@ -1011,11 +1011,11 @@ class StreamingOuterJoinSuite extends StreamTest with StateStoreMetricsTest with
1011
1012
val joined = df1.as("left")
1013
.join(df2.as("right"),
1014
- expr(s"""
1015
- |left.id = right.id AND left.eventTime BETWEEN
1016
- | right.eventTime - INTERVAL 30 seconds AND
1017
- | right.eventTime + INTERVAL 30 seconds
1018
- """.stripMargin),
+ expr("""
+ |left.id = right.id AND left.eventTime BETWEEN
+ | right.eventTime - INTERVAL 30 seconds AND
+ | right.eventTime + INTERVAL 30 seconds
+ """.stripMargin),
1019
joinType = "leftOuter")
1020
1021
val inputDataForInput1 = Seq(
0 commit comments