StreamManager streamManager = getStreamManager("events");
streamManager.send("15");
streamManager.send("16");
streamManager.send("17");
final long startTime = System.currentTimeMillis();
<BUG>MapReduceManager mapReduceManager =
appManager.startMapReduce("StreamConversionMapReduce", RuntimeArguments.NO_ARGUMENTS);
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);</BUG>
long partitionTime = assertWithRetry(new Callable<Long>() {
@Override

StreamManager streamManager = getStreamManager("events");
streamManager.send("15");
streamManager.send("16");
streamManager.send("17");
final long startTime = System.currentTimeMillis();
MapReduceManager mapReduceManager = appManager.getMapReduceManager("StreamConversionMapReduce");
mapReduceManager.start(RuntimeArguments.NO_ARGUMENTS);
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);
long partitionTime = assertWithRetry(new Callable<Long>() {
@Override
