[quickstart] Error msg in streaming quickstarts when run with wrong n…

…umber of arguments
nltran · Apr 8, 2015 · f07aa01 · f07aa01
1 parent e8faff7
commit f07aa01
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/...-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java b/...-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
@@ -57,6 +57,11 @@ public class SocketTextStreamWordCount {
 
  public static void main(String[] args) throws Exception {
 
+ if (args.length != 2){
+ System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>");
+ return;
+ }
+
  String hostName = args[0];
  Integer port = Integer.parseInt(args[1]);
 

diff --git a/...ala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala b/...ala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
@@ -45,6 +45,10 @@ import org.apache.flink.streaming.api.scala._
 object SocketTextStreamWordCount {
 
  def main(args: Array[String]) {
+ if (args.length != 2) {
+ System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>")
+ return
+ }
 
  val hostName = args(0)
  val port = args(1).toInt