We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ae4ac91 commit f3935aaCopy full SHA for f3935aa
job-server/test/spark.jobserver/JobManagerSpec.scala
@@ -28,7 +28,7 @@ abstract class JobManagerSpec extends JobSpecBase(JobManagerSpec.getNewSystem) {
28
it("should return error message if classPath does not match") {
29
uploadTestJar()
30
manager ! JobManagerActor.Initialize
31
- expectMsgClass(classOf[JobManagerActor.Initialized])
+ expectMsgClass(Duration(6, SECONDS), classOf[JobManagerActor.Initialized])
32
manager ! JobManagerActor.StartJob("demo", "no.such.class", emptyConfig, Set.empty[Class[_]])
33
expectMsg(CommonMessages.NoSuchClass)
34
}
0 commit comments