You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/04/08 15:36:51 UTC
flink git commit: [quickstart] Error msg in streaming quickstarts
when run with wrong number of arguments
Repository: flink
Updated Branches:
refs/heads/master e8faff795 -> f07aa014d
[quickstart] Error msg in streaming quickstarts when run with wrong number of arguments
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f07aa014
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f07aa014
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f07aa014
Branch: refs/heads/master
Commit: f07aa014d40eea13363fd1d042ffcc0e27341a92
Parents: e8faff7
Author: mbalassi <mb...@apache.org>
Authored: Wed Apr 8 15:34:03 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Wed Apr 8 15:36:09 2015 +0200
----------------------------------------------------------------------
.../src/main/java/SocketTextStreamWordCount.java | 5 +++++
.../src/main/scala/SocketTextStreamWordCount.scala | 4 ++++
2 files changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/f07aa014/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java b/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
index 3067c17..3888d7b 100644
--- a/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/main/java/SocketTextStreamWordCount.java
+++ b/flink-quickstart/flink-quickstart-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]);
http://git-wip-us.apache.org/repos/asf/flink/blob/f07aa014/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
----------------------------------------------------------------------
diff --git a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala b/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
index a065807..63d840d 100644
--- a/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/src/main/scala/SocketTextStreamWordCount.scala
+++ b/flink-quickstart/flink-quickstart-scala/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