I don’t think there are test cases for Worker itself
You can val actorRef = TestActorRef[Master](Props(classOf[Master], ...))(actorSystem) actorRef.underlyingActor.receive(Heartbeat) and use expectMsg to test if Master can reply correct message by assuming Worker is absolutely correct Then in another test case to test if Worker can send register message to Master after receiving Master’s “re-register” instruction, (in this test case assuming that the Master is absolutely right) Best, -- Nan Zhu On Wednesday, October 15, 2014 at 2:04 PM, Matthew Cheah wrote: > Thanks, the example was helpful. > > However, testing the Worker itself is a lot more complicated than > WorkerWatcher, since the Worker class is quite a bit more complex. Are there > any tests that inspect the Worker itself? > > Thanks, > > -Matt Cheah > > On Tue, Oct 14, 2014 at 6:40 PM, Nan Zhu <zhunanmcg...@gmail.com > (mailto:zhunanmcg...@gmail.com)> wrote: > > You can use akka testkit > > > > Example: > > > > https://github.com/apache/spark/blob/ef4ff00f87a4e8d38866f163f01741c2673e41da/core/src/test/scala/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala > > > > > > -- > > Nan Zhu > > > > > > On Tuesday, October 14, 2014 at 9:17 PM, Matthew Cheah wrote: > > > > > Hi everyone, > > > > > > I’m adding some new message passing between the Master and Worker actors > > > in > > > order to address https://issues.apache.org/jira/browse/SPARK-3736 . > > > > > > I was wondering if these kinds of interactions are tested in the automated > > > Jenkins test suite, and if so, where I could find some examples to help me > > > do the same. > > > > > > Thanks! > > > > > > -Matt Cheah > > >
