FileSetArguments.setInputPath(inputArgs, "nn.1");
FileSetArguments.addInputPath(inputArgs, "nn.2");
FileSetArguments.setOutputPath(outputArgs, "out.2");
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "lines", inputArgs));
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "counts", outputArgs));
<BUG>mapReduceManager = applicationManager.startMapReduce("WordCount", runtimeArguments);

mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);</BUG>
DataSetManager<FileSet> countsManager = getDataset("counts");
counts.clear();

FileSetArguments.setInputPath(inputArgs, "nn.1");
FileSetArguments.addInputPath(inputArgs, "nn.2");
FileSetArguments.setOutputPath(outputArgs, "out.2");
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "lines", inputArgs));
runtimeArguments.putAll(RuntimeArguments.addScope(Scope.DATASET, "counts", outputArgs));
mapReduceManager = applicationManager.getMapReduceManager("WordCount");
mapReduceManager.start(runtimeArguments);
mapReduceManager.waitForFinish(5, TimeUnit.MINUTES);
DataSetManager<FileSet> countsManager = getDataset("counts");
counts.clear();
