ApplicationManager applicationManager = deployApplication(appClass);
StreamManager streamManager = getStreamManager(streamWriter);
for (int i = 0; i < 50; i++) {
streamManager.send(String.valueOf(i));
}
<BUG>MapReduceManager mapReduceManager = applicationManager.startMapReduce(mapReduceName);

mapReduceManager.waitForFinish(timeout, TimeUnit.SECONDS);</BUG>
DataSetManager<KeyValueTable> datasetManager = applicationManager.getDataSet("results");
KeyValueTable results = datasetManager.get();

ApplicationManager applicationManager = deployApplication(appClass);
StreamManager streamManager = getStreamManager(streamWriter);
for (int i = 0; i < 50; i++) {
streamManager.send(String.valueOf(i));
}
MapReduceManager mapReduceManager = applicationManager.getMapReduceManager(mapReduceName);
mapReduceManager.start();
mapReduceManager.waitForFinish(timeout, TimeUnit.SECONDS);
DataSetManager<KeyValueTable> datasetManager = applicationManager.getDataSet("results");
KeyValueTable results = datasetManager.get();
