[streaming] Logger updated, only streaming is logged

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/streamcomponent/StreamInvokableComponent.java

@@ -49,7 +49,7 @@ public abstract class StreamInvokableComponent {
 		try {
 			for (RecordWriter<StreamRecord> output : outputs) {
 				output.emit(record);
-				log.debug("EMITTED: " + record.getId() + " -- " + name);
+				log.info("EMITTED: " + record.getId() + " -- " + name);
 			}
 		} catch (Exception e) {
 			log.warn("EMIT ERROR: " + e.getMessage() + " -- " + name);

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/batch/BatchForwardLocal.java

@@ -78,7 +78,7 @@ public class BatchForwardLocal {
 				Client client = new Client(new InetSocketAddress(
 						"hadoop02.ilab.sztaki.hu", 6123), configuration);
 
-				client.run(null, jG, true);
+				client.run( jG, true);
 
 			}
 

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/wordcount/WordCountLocal.java

@@ -46,15 +46,23 @@ public class WordCountLocal {
 		return graphBuilder.getJobGraph();
 	}
 
-	public static void main(String[] args) {
-
-		Logger root = Logger.getRootLogger();
-		root.removeAllAppenders();
+	public static void setLogger() {
+		Logger logger = Logger.getLogger("eu.stratosphere.streaming");
+		logger.removeAllAppenders();
 		PatternLayout layout = new PatternLayout(
 				"%d{HH:mm:ss,SSS} %-5p %-60c %x - %m%n");
 		ConsoleAppender appender = new ConsoleAppender(layout, "System.err");
+		logger.addAppender(appender);
+		logger.setLevel(Level.DEBUG);
+		
+		Logger root = Logger.getRootLogger();
+		root.removeAllAppenders();
 		root.addAppender(appender);
-		root.setLevel(Level.DEBUG);
+		root.setLevel(Level.ERROR);
+	}
+	
+	public static void main(String[] args) {
+		setLogger();
 
 		try {