This is an automated email from the ASF dual-hosted git repository.
sarutak 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 b9d6473 [SPARK-35593][K8S][TESTS][FOLLOWUP] Increase timeout in
KubernetesLocalDiskShuffleDataIOSuite
b9d6473 is described below
commit b9d6473e898cea255bbbc27f657e2958fd4c011b
Author: Dongjoon Hyun <dongj...@apache.org>
AuthorDate: Sat Jun 19 15:22:29 2021 +0900
[SPARK-35593][K8S][TESTS][FOLLOWUP] Increase timeout in
KubernetesLocalDiskShuffleDataIOSuite
### What changes were proposed in this pull request?
This increases the timeout from 10 seconds to 60 seconds in
KubernetesLocalDiskShuffleDataIOSuite to reduce the flakiness.
### Why are the changes needed?
-
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/140003/testReport/
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Pass the CIs
Closes #32967 from dongjoon-hyun/SPARK-35593-2.
Authored-by: Dongjoon Hyun <dongj...@apache.org>
Signed-off-by: Kousuke Saruta <saru...@oss.nttdata.com>
---
.../apache/spark/shuffle/KubernetesLocalDiskShuffleDataIOSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/shuffle/KubernetesLocalDiskShuffleDataIOSuite.scala
b/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/shuffle/KubernetesLocalDiskShuffleDataIOSuite.scala
index e94e8dd..eca38a8 100644
---
a/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/shuffle/KubernetesLocalDiskShuffleDataIOSuite.scala
+++
b/resource-managers/kubernetes/core/src/test/scala/org/apache/spark/shuffle/KubernetesLocalDiskShuffleDataIOSuite.scala
@@ -210,7 +210,7 @@ class KubernetesLocalDiskShuffleDataIOSuite extends
SparkFunSuite with LocalSpar
assert(master.shuffleStatuses(1).mapStatuses.forall(_ == null))
}
sc.parallelize(Seq((1, 1)), 2).groupByKey().collect()
- eventually(timeout(10.second), interval(1.seconds)) {
+ eventually(timeout(60.second), interval(1.seconds)) {
assert(master.shuffleStatuses(0).mapStatuses.map(_.mapId).toSet ==
Set(0, 1, 2))
assert(master.shuffleStatuses(1).mapStatuses.map(_.mapId).toSet ==
Set(6, 7, 8))
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
