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

mrManager.waitForFinish(180, TimeUnit.SECONDS);</BUG>
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> outDataSet =
applicationManager.getDataSet(TestMapReduceServiceIntegrationApp.OUTPUT_DATASET);

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);
mrManager.start();
mrManager.waitForFinish(180, TimeUnit.SECONDS);
DataSetManager<MyKeyValueTableDefinition.KeyValueTable> outDataSet =
applicationManager.getDataSet(TestMapReduceServiceIntegrationApp.OUTPUT_DATASET);
