From 30f9562b96e49977f9c73cabe878e1d9d0116a4e Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Fri, 3 May 2024 15:36:22 -0700 Subject: [PATCH] [SPARK-47097][CONNECT][TESTS][FOLLOWUP] Increase timeout to 1 minute for `interrupt tag` 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.")