This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch branch-3.4
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.4 by this push:
new 77e077a96f7 [SPARK-43973][SS][UI][TESTS][FOLLOWUP][3.4] Fix
compilation by switching QueryTerminatedEvent constructor
77e077a96f7 is described below
commit 77e077a96f7dafb1f43af7e9f7b495dce6b1e18a
Author: Dongjoon Hyun <dongj...@apache.org>
AuthorDate: Tue Jun 6 11:30:32 2023 -0700
[SPARK-43973][SS][UI][TESTS][FOLLOWUP][3.4] Fix compilation by switching
QueryTerminatedEvent constructor
### What changes were proposed in this pull request?
This is a follow-up of https://github.com/apache/spark/pull/41468 to fix
`branch-3.4`'s compilation issue.
### Why are the changes needed?
To recover the compilation.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
Closes #41484 from dongjoon-hyun/SPARK-43973.
Authored-by: Dongjoon Hyun <dongj...@apache.org>
Signed-off-by: Dongjoon Hyun <dongj...@apache.org>
---
.../spark/sql/streaming/ui/StreamingQueryStatusListenerSuite.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListenerSuite.scala
b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListenerSuite.scala
index 4b6d2dc4562..b01abd8032b 100644
---
a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListenerSuite.scala
+++
b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ui/StreamingQueryStatusListenerSuite.scala
@@ -279,7 +279,7 @@ class StreamingQueryStatusListenerSuite extends StreamTest {
val startEvent1 = new StreamingQueryListener.QueryStartedEvent(
id1, runId1, "test1", "2023-01-01T20:50:00.800Z")
listener.onQueryStarted(startEvent1)
- val terminateEvent1 = new StreamingQueryListener.QueryTerminatedEvent(id1,
runId1, None, None)
+ val terminateEvent1 = new StreamingQueryListener.QueryTerminatedEvent(id1,
runId1, None)
listener.onQueryTerminated(terminateEvent1)
// failure (has exception) case
@@ -289,7 +289,7 @@ class StreamingQueryStatusListenerSuite extends StreamTest {
id2, runId2, "test2", "2023-01-02T20:54:20.827Z")
listener.onQueryStarted(startEvent2)
val terminateEvent2 = new StreamingQueryListener.QueryTerminatedEvent(
- id2, runId2, Option("ExampleException"), Option("EXAMPLE_ERROR_CLASS"))
+ id2, runId2, Option("ExampleException"))
listener.onQueryTerminated(terminateEvent2)
// check results
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
