void configureJobNode(ApplicationDescriptorImpl mockStreamAppDesc) {
    JobGraph jobGraph = new ExecutionPlanner(mockConfig, mock(StreamManager.class))
        .createJobGraph(mockStreamAppDesc);
    mockJobNode = spy(jobGraph.getJobNodes().get(0));
  }
Unit test base class to set up commonly used test application and configuration.
samza-core/src/test/java/org/apache/samza/execution/ExecutionPlannerTestBase.java