diff --git a/src/main/java/spouts/WordReader.java b/src/main/java/spouts/WordReader.java index 03afae2..4883449 100644 --- a/src/main/java/spouts/WordReader.java +++ b/src/main/java/spouts/WordReader.java @@ -67,7 +67,7 @@ public void open(Map conf, TopologyContext context, try { this.fileReader = new FileReader(conf.get("wordsFile").toString()); } catch (FileNotFoundException e) { - throw new RuntimeException("Error reading file ["+conf.get("wordFile")+"]"); + throw new RuntimeException("Error reading file ["+conf.get("wordsFile")+"]"); } this.collector = collector; }