#65

src/main/java/teetime/stage/basic/merger/Merger.java

@@ -86,7 +86,7 @@ public final class Merger<T> extends AbstractStage {
 
 			if (set.size() == this.getInputPorts().length) {
 				signal.trigger(this);
-				this.outputPort.sendSignal(signal);
+				// this.outputPort.sendSignal(signal);
 				signalMap.remove(signal.getClass());
 			}
 		} else {

src/test/java/teetime/stage/WordCountingTest.java

@@ -12,7 +12,7 @@ public class WordCountingTest {
 
 	@Test
 	public void test1() {
-		WordCountingConfiguration wcc = new WordCountingConfiguration(1, new File("src/test/resources/data/output.txt"), new File(
+		WordCountingConfiguration wcc = new WordCountingConfiguration(3, new File("src/test/resources/data/output.txt"), new File(
 				"src/test/resources/data/output.txt"));
 		Analysis analysis = new Analysis(wcc);
 		analysis.start();