Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/18396
This looks weird. Many documentation goes mismatched after `afterAll` and
`BeforeAndAfterAll` which do not look related with the documentation failure.
I just tested before this PR -
https://gist.github.com/HyukjinKwon/ca77ffb7848af00c8a67e6e050b716a3
after this PR -
https://gist.github.com/HyukjinKwon/481ca9e8aad918f4757eb0c8efb06ee4
To unblock the PR, (just based on my wild guess) I tried and found that a
weird workaround was relocating.
```
---
a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala
+++
b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala
@@ -216,6 +216,11 @@ trait StreamTest extends QueryTest with
SharedSQLContext with Timeouts with Befo
AssertOnQuery(query => { func(query); true })
}
+ override def afterAll(): Unit = {
+ super.afterAll()
+ StateStore.stop() // stop the state store maintenance thread and
unload store providers
+ }
+
/**
* Executes the specified actions on the given streaming DataFrame and
provides helpful
* error messages in the case of failures or incorrect answers.
@@ -661,11 +666,6 @@ trait StreamTest extends QueryTest with
SharedSQLContext with Timeouts with Befo
testStream(ds)(actions: _*)
}
- override def afterAll(): Unit = {
- super.afterAll()
- StateStore.stop() // stop the state store maintenance thread and
unload store providers
- }
-
object AwaitTerminationTester {
```
Let me try to prepare minimal reproduction and open an issue to GenJavaDoc.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
