serviceManager.waitForStatus(true);
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> inDataSet =
applicationManager.getDataSet(TestMapReduceServiceIntegrationApp.INPUT_DATASET);
inDataSet.get().write("key1", "Two words");
inDataSet.get().write("key2", "Plus three words");
<BUG>inDataSet.flush();
MapReduceManager mrManager = applicationManager.getMapReduceManager(TestMapReduceServiceIntegrationApp.MR_NAME);

mrManager.start();</BUG>
mrManager.waitForFinish(180, TimeUnit.SECONDS);

serviceManager.waitForStatus(true);
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> inDataSet =
applicationManager.getDataSet(TestMapReduceServiceIntegrationApp.INPUT_DATASET);
inDataSet.get().write("key1", "Two words");
inDataSet.get().write("key2", "Plus three words");
inDataSet.flush();
MapReduceManager mrManager =
applicationManager.getMapReduceManager(TestMapReduceServiceIntegrationApp.MR_NAME).start();
mrManager.waitForFinish(180, TimeUnit.SECONDS);
