[streaming] Repository change to dms.sztaki.hu/maven-public

flink-addons/flink-streaming/pom.xml

@@ -14,7 +14,7 @@
 	<repositories>
 		<repository>
 			<id>snapshots-repo</id>
-			<url>https://oss.sonatype.org/content/repositories/snapshots</url>
+            <url>https://dms.sztaki.hu/maven-public</url>
 			<releases><enabled>false</enabled></releases>
 			<snapshots><enabled>true</enabled></snapshots>
 		</repository>

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

@@ -17,10 +17,7 @@ package eu.stratosphere.streaming.test.batch;
 
 import java.net.InetSocketAddress;
 
-import org.apache.log4j.ConsoleAppender;
 import org.apache.log4j.Level;
-import org.apache.log4j.Logger;
-import org.apache.log4j.PatternLayout;
 
 import eu.stratosphere.client.minicluster.NepheleMiniCluster;
 import eu.stratosphere.client.program.Client;
@@ -63,7 +60,7 @@ public class BatchForwardLocal {
 				Client client = new Client(new InetSocketAddress("localhost",
 						6498), configuration);
 
-				client.run(null, jG, true);
+				client.run(jG, true);
 
 				exec.stop();
 
@@ -73,7 +70,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/batch/wordcount/BatchWordCountLocal.java

@@ -17,10 +17,7 @@ package eu.stratosphere.streaming.test.batch.wordcount;
 
 import java.net.InetSocketAddress;
 
-import org.apache.log4j.ConsoleAppender;
 import org.apache.log4j.Level;
-import org.apache.log4j.Logger;
-import org.apache.log4j.PatternLayout;
 
 import eu.stratosphere.client.minicluster.NepheleMiniCluster;
 import eu.stratosphere.client.program.Client;
@@ -74,7 +71,7 @@ public class BatchWordCountLocal {
 				Client client = new Client(new InetSocketAddress("localhost",
 						6498), configuration);
 
-				client.run(null, jG, true);
+				client.run(jG, true);
 
 				exec.stop();
 
@@ -84,7 +81,7 @@ public class BatchWordCountLocal {
 				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/cellinfo/CellInfo.java

@@ -87,7 +87,7 @@ public class CellInfo {
 			Client client = new Client(new InetSocketAddress(
 					"hadoop02.ilab.sztaki.hu", 6123), configuration);
 			exec.start();
-			client.run(null, jG, true);
+			client.run(jG, true);
 			exec.stop();
 		} catch (Exception e) {
 			System.out.println(e);

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

@@ -17,10 +17,7 @@ package eu.stratosphere.streaming.test.window.wordcount;
 
 import java.net.InetSocketAddress;
 
-import org.apache.log4j.ConsoleAppender;
 import org.apache.log4j.Level;
-import org.apache.log4j.Logger;
-import org.apache.log4j.PatternLayout;
 
 import eu.stratosphere.client.minicluster.NepheleMiniCluster;
 import eu.stratosphere.client.program.Client;
@@ -75,7 +72,7 @@ public class WindowWordCountLocal {
 				Client client = new Client(new InetSocketAddress("localhost",
 						6498), configuration);
 
-				client.run(null, jG, true);
+				client.run(jG, true);
 
 				exec.stop();
 
@@ -85,7 +82,7 @@ public class WindowWordCountLocal {
 				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

@@ -65,7 +65,7 @@ public class WordCountLocal {
 				Client client = new Client(new InetSocketAddress("localhost",
 						6498), configuration);
 
-				client.run(null, jG, true);
+				client.run(jG, true);
 
 				exec.stop();
 			} else if (args[0].equals("cluster")) {
@@ -74,7 +74,7 @@ public class WordCountLocal {
 				Client client = new Client(new InetSocketAddress(
 						"hadoop02.ilab.sztaki.hu", 6123), configuration);
 
-				client.run(null, jG, true);
+				client.run(jG, true);
 			}
 
 		} catch (Exception e) {

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

@@ -18,10 +18,7 @@ package eu.stratosphere.streaming.test.wordcount;
 import java.io.File;
 import java.net.InetSocketAddress;
 
-import org.apache.log4j.ConsoleAppender;
 import org.apache.log4j.Level;
-import org.apache.log4j.Logger;
-import org.apache.log4j.PatternLayout;
 
 import eu.stratosphere.client.program.Client;
 import eu.stratosphere.client.program.JobWithJars;
@@ -67,7 +64,7 @@ public class WordCountRemote {
 			Client client = new Client(new InetSocketAddress(
 					"hadoop02.ilab.sztaki.hu", 6123), configuration);
 
-			client.run(null, jG, true);
+			client.run(jG, true);
 
 		} catch (Exception e) {
 			System.out.println(e);

flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamcomponent/StreamComponentTest.java

@@ -126,7 +126,7 @@ public class StreamComponentTest {
 			Client client = new Client(new InetSocketAddress("localhost",
 					6498), configuration);
 
-			client.run(null, jG, true);
+			client.run(jG, true);
 
 			exec.stop();
 		} catch (Exception e) {