Skip to content

Commit

Permalink
rdar://81168472: Backport SPARK-10816 EventTime based sessionization …
Browse files Browse the repository at this point in the history
…(session window). Fix test error.
  • Loading branch information
viirya authored and dongjoon-hyun committed Jul 29, 2021
1 parent 274ebac commit abf48b1
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -239,7 +239,7 @@ class DataFrameTimeWindowingSuite extends QueryTest with SharedSparkSession {
df.select(window($"time", "10 second"), window($"time", "15 second")).collect()
}
assert(e.getMessage.contains(
"Multiple time/session window expressions would result in a cartesian product"))
"Multiple time window expressions would result in a cartesian product"))
}

test("aliased windows") {
Expand Down

0 comments on commit abf48b1

Please sign in to comment.