From 8bc6df2c2e86d917e48c4debd78e87f714a27151 Mon Sep 17 00:00:00 2001 From: HyukjinKwon Date: Mon, 18 May 2020 09:45:15 +0900 Subject: [PATCH] Increase the eventually time limit for Mino kdc in tests to fix flakiness --- .../deploy/security/HadoopDelegationTokenManagerSuite.scala | 2 +- .../scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/test/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManagerSuite.scala b/core/src/test/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManagerSuite.scala index fc28968922c7a..d9d559509f4fb 100644 --- a/core/src/test/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManagerSuite.scala +++ b/core/src/test/scala/org/apache/spark/deploy/security/HadoopDelegationTokenManagerSuite.scala @@ -103,7 +103,7 @@ class HadoopDelegationTokenManagerSuite extends SparkFunSuite { // The workaround here is to periodically repeat this process with a timeout , since we are // using Hadoop 2.7.4 as default. // https://issues.apache.org/jira/browse/SPARK-31631 - eventually(timeout(10.seconds), interval(1.second)) { + eventually(timeout(60.seconds), interval(1.second)) { try { kdc = new MiniKdc(kdcConf, kdcDir) kdc.start() diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala index e1e44b1e59f70..275a8170182fe 100644 --- a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala +++ b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala @@ -146,7 +146,7 @@ class KafkaTestUtils( // The workaround here is to periodically repeat this process with a timeout , since we are // using Hadoop 2.7.4 as default. // https://issues.apache.org/jira/browse/SPARK-31631 - eventually(timeout(10.seconds), interval(1.second)) { + eventually(timeout(60.seconds), interval(1.second)) { try { kdc = new MiniKdc(kdcConf, kdcDir) kdc.start()