public class MapReduceServiceIntegrationTestRun extends TestFrameworkTestBase {
@Test
public void test() throws Exception {
ApplicationManager applicationManager = deployApplication(TestMapReduceServiceIntegrationApp.class);
ServiceManager serviceManager =
<BUG>applicationManager.getServiceManager(TestMapReduceServiceIntegrationApp.SERVICE_NAME);

serviceManager.start();</BUG>
serviceManager.waitForStatus(true);
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> inDataSet =

public class MapReduceServiceIntegrationTestRun extends TestFrameworkTestBase {
@Test
public void test() throws Exception {
ApplicationManager applicationManager = deployApplication(TestMapReduceServiceIntegrationApp.class);
ServiceManager serviceManager =
applicationManager.getServiceManager(TestMapReduceServiceIntegrationApp.SERVICE_NAME).start();
serviceManager.waitForStatus(true);
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> inDataSet =
