diff --git a/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/BatchesResourceSuite.scala b/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/BatchesResourceSuite.scala index 65c58c6cb0b..fd4cca329f9 100644 --- a/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/BatchesResourceSuite.scala +++ b/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/BatchesResourceSuite.scala @@ -751,9 +751,15 @@ abstract class BatchesResourceSuiteBase extends KyuubiFunSuite getBatchJobSubmissionStateCounter(OperationState.ERROR) val batchId = UUID.randomUUID().toString - val requestObj = newSparkBatchRequest(Map( - "spark.master" -> "local", - KYUUBI_BATCH_ID_KEY -> batchId)) + val requestObj = newBatchRequest( + sparkBatchTestBatchType, + sparkBatchTestResource.get, + "org.apache.spark.examples.DriverSubmissionTest", + "DriverSubmissionTest-" + batchId, + Map( + "spark.master" -> "local", + KYUUBI_BATCH_ID_KEY -> batchId), + Seq("120")) eventually(timeout(10.seconds)) { val response = webTarget.path("api/v1/batches")