FileSetArguments.setInputPaths(inputArgs, "nn.1");
Map<String, String> outputArgs = Maps.newHashMap();
FileSetArguments.setOutputPath(outputArgs, "out.1");
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "lines", inputArgs));
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "counts", outputArgs));
<BUG>MapReduceManager mapReduceManager = applicationManager.getMapReduceManager("WordCount");

mapReduceManager.start(runtimeArguments);</BUG>
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);
Map<String, Integer> counts = Maps.newHashMap();

FileSetArguments.setInputPaths(inputArgs, "nn.1");
Map<String, String> outputArgs = Maps.newHashMap();
FileSetArguments.setOutputPath(outputArgs, "out.1");
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "lines", inputArgs));
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "counts", outputArgs));
MapReduceManager mapReduceManager = applicationManager.getMapReduceManager("WordCount").start(runtimeArguments);
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);
Map<String, Integer> counts = Maps.newHashMap();
