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()