import org.junit.Test;
import java.util.concurrent.TimeUnit;
public class MapReduceServiceIntegrationTestRun extends TestFrameworkTestBase {
@Test
public void test() throws Exception {
<BUG>ApplicationManager applicationManager = deployApplication(TestMapReduceServiceIntegrationApp.class);
ServiceManager serviceManager = applicationManager.startService(TestMapReduceServiceIntegrationApp.SERVICE_NAME);

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

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