[streaming] WordCount performance

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/wordcount/WordCountCounter.java

@@ -59,8 +59,8 @@ public class WordCountCounter extends UserTaskInvokable {
 
 	@Override
 	public String getResult() {
-		pCounter.writeCSV("/home/strato/stratosphere-distrib/log/counter/Counter" + channelID + "-1.csv");
-		pTimer.writeCSV("/home/strato/stratosphere-distrib/log/timer/Counter" + channelID + "-1.csv");
+		pCounter.writeCSV("/home/strato/stratosphere-distrib/log/counter/Counter" + channelID);
+		pTimer.writeCSV("/home/strato/stratosphere-distrib/log/timer/Counter" + channelID);
 		return "";
 	}
 }

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/wordcount/WordCountSink.java

@@ -30,7 +30,7 @@ public class WordCountSink extends UserSinkInvokable {
 
 	@Override
 	public String getResult() {
-		perf.writeCSV("/home/strato/stratosphere-distrib/log/counter/Sink" + "-1.csv");
+		perf.writeCSV("/home/strato/stratosphere-distrib/log/counter/Sink");
 		return "";
 	}
 

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/wordcount/WordCountSourceSplitter.java

@@ -64,8 +64,8 @@ public class WordCountSourceSplitter extends UserSourceInvokable {
 
 	@Override
 	public String getResult() {
-		pCounter.writeCSV("/home/strato/stratosphere-distrib/log/counter/Source" + channelID + "-1.csv");
-		pTimer.writeCSV("/home/strato/stratosphere-distrib/log/timer/Source" + channelID + "-1.csv");
+		pCounter.writeCSV("/home/strato/stratosphere-distrib/log/counter/Source" + channelID);
+		pTimer.writeCSV("/home/strato/stratosphere-distrib/log/timer/Source" + channelID);
 
 		return "";
 	}