nodeState = nodeStates.get(AppWithWorkflow.SampleWorkflow.WORD_COUNT_MR);
Assert.assertTrue(AppWithWorkflow.SampleWorkflow.WORD_COUNT_MR.equals(nodeState.getNodeId()));
Assert.assertTrue(NodeStatus.COMPLETED == nodeState.getNodeStatus());
}
private String createInput(String folderName) throws IOException {
<BUG>File inputDir = tmpFolder.newFolder(folderName);
</BUG>
File inputFile = new File(inputDir.getPath() + "/words.txt");
try (BufferedWriter writer = Files.newBufferedWriter(inputFile.toPath(), Charsets.UTF_8)) {
writer.write("this text has");

nodeState = nodeStates.get(AppWithWorkflow.SampleWorkflow.WORD_COUNT_MR);
Assert.assertTrue(AppWithWorkflow.SampleWorkflow.WORD_COUNT_MR.equals(nodeState.getNodeId()));
Assert.assertTrue(NodeStatus.COMPLETED == nodeState.getNodeStatus());
}
private String createInput(String folderName) throws IOException {
File inputDir = TMP_FOLDER.newFolder(folderName);
File inputFile = new File(inputDir.getPath() + "/words.txt");
try (BufferedWriter writer = Files.newBufferedWriter(inputFile.toPath(), Charsets.UTF_8)) {
writer.write("this text has");
