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.startMapReduce("WordCount", runtimeArguments);

mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);</BUG>
Map<String, Integer> counts = Maps.newHashMap();
connection = (HttpURLConnection) new URL(serviceURL, "counts?path=out.1/part-r-00000").openConnection();

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");
mapReduceManager.start(runtimeArguments);
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);
Map<String, Integer> counts = Maps.newHashMap();
connection = (HttpURLConnection) new URL(serviceURL, "counts?path=out.1/part-r-00000").openConnection();
