This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 7f08df4af95d [SPARK-47097][CONNECT][TESTS][FOLLOWUP] Increase timeout
to `1 minute` for `interrupt tag` test
7f08df4af95d is described below
commit 7f08df4af95d20f3fd056588b5a3cfa5f5c57654
Author: Dongjoon Hyun <dh...@apple.com>
AuthorDate: Fri May 3 16:54:24 2024 -0700
[SPARK-47097][CONNECT][TESTS][FOLLOWUP] Increase timeout to `1 minute` for
`interrupt tag` test
### What changes were proposed in this pull request?
This is a follow-up to increase `timeout` from `30s` to `1 minute` like the
other timeouts of the same test case.
- #45173
### Why are the changes needed?
To reduce the flakiness more. The following is the recent failure on
`master` branch.
- https://github.com/apache/spark/actions/runs/8944948827/job/24572965877
- https://github.com/apache/spark/actions/runs/8945375279/job/24574263993
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #46374 from dongjoon-hyun/SPARK-47097.
Authored-by: Dongjoon Hyun <dh...@apple.com>
Signed-off-by: Dongjoon Hyun <dh...@apple.com>
---
.../src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala
b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala
index b967245d90c2..d1015d55b1df 100644
---
a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala
+++
b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/SparkSessionE2ESuite.scala
@@ -196,7 +196,7 @@ class SparkSessionE2ESuite extends RemoteSparkSession {
// q2 and q3 should be cancelled
interrupted.clear()
- eventually(timeout(30.seconds), interval(1.seconds)) {
+ eventually(timeout(1.minute), interval(1.seconds)) {
val ids = spark.interruptTag("two")
interrupted ++= ids
assert(interrupted.length == 2, s"Interrupted operations: $interrupted.")
@@ -213,7 +213,7 @@ class SparkSessionE2ESuite extends RemoteSparkSession {
// q1 and q4 should be cancelled
interrupted.clear()
- eventually(timeout(30.seconds), interval(1.seconds)) {
+ eventually(timeout(1.minute), interval(1.seconds)) {
val ids = spark.interruptTag("one")
interrupted ++= ids
assert(interrupted.length == 2, s"Interrupted operations: $interrupted.")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
