spark git commit: Update JavaCustomReceiver.java
Repository: spark
Updated Branches:
refs/heads/master d6e555244 - 7c9ec529a
Update JavaCustomReceiver.java
æ°ç»ä¸æ è¶ç
Author: xiao321 1042460...@qq.com
Closes #3153 from xiao321/patch-1 and squashes the following commits:
0ed17b5 [xiao321] Update JavaCustomReceiver.java
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/7c9ec529
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/7c9ec529
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/7c9ec529
Branch: refs/heads/master
Commit: 7c9ec529a3483fab48f728481dd1d3663369e50a
Parents: d6e5552
Author: xiao321 1042460...@qq.com
Authored: Fri Nov 7 12:56:49 2014 -0800
Committer: Tathagata Das tathagata.das1...@gmail.com
Committed: Fri Nov 7 12:56:49 2014 -0800
--
.../org/apache/spark/examples/streaming/JavaCustomReceiver.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/spark/blob/7c9ec529/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
--
diff --git
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
index 981bc4f..99df259 100644
---
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
+++
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
@@ -70,7 +70,7 @@ public class JavaCustomReceiver extends ReceiverString {
// Create a input stream with the custom receiver on target ip:port and
count the
// words in input stream of \n delimited text (eg. generated by 'nc')
JavaReceiverInputDStreamString lines = ssc.receiverStream(
- new JavaCustomReceiver(args[1], Integer.parseInt(args[2])));
+ new JavaCustomReceiver(args[0], Integer.parseInt(args[1])));
JavaDStreamString words = lines.flatMap(new FlatMapFunctionString,
String() {
@Override
public IterableString call(String x) {
-
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: Update JavaCustomReceiver.java
Repository: spark
Updated Branches:
refs/heads/branch-1.2 47bd8f302 - 8cefb63c1
Update JavaCustomReceiver.java
æ°ç»ä¸æ è¶ç
Author: xiao321 1042460...@qq.com
Closes #3153 from xiao321/patch-1 and squashes the following commits:
0ed17b5 [xiao321] Update JavaCustomReceiver.java
(cherry picked from commit 7c9ec529a3483fab48f728481dd1d3663369e50a)
Signed-off-by: Tathagata Das tathagata.das1...@gmail.com
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/8cefb63c
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/8cefb63c
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/8cefb63c
Branch: refs/heads/branch-1.2
Commit: 8cefb63c122e7c7cf4af959f9606f4491148d9f4
Parents: 47bd8f3
Author: xiao321 1042460...@qq.com
Authored: Fri Nov 7 12:56:49 2014 -0800
Committer: Tathagata Das tathagata.das1...@gmail.com
Committed: Fri Nov 7 12:57:17 2014 -0800
--
.../org/apache/spark/examples/streaming/JavaCustomReceiver.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/spark/blob/8cefb63c/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
--
diff --git
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
index 981bc4f..99df259 100644
---
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
+++
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
@@ -70,7 +70,7 @@ public class JavaCustomReceiver extends ReceiverString {
// Create a input stream with the custom receiver on target ip:port and
count the
// words in input stream of \n delimited text (eg. generated by 'nc')
JavaReceiverInputDStreamString lines = ssc.receiverStream(
- new JavaCustomReceiver(args[1], Integer.parseInt(args[2])));
+ new JavaCustomReceiver(args[0], Integer.parseInt(args[1])));
JavaDStreamString words = lines.flatMap(new FlatMapFunctionString,
String() {
@Override
public IterableString call(String x) {
-
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: Update JavaCustomReceiver.java
Repository: spark
Updated Branches:
refs/heads/branch-1.1 0a40eac25 - 4fb26df87
Update JavaCustomReceiver.java
æ°ç»ä¸æ è¶ç
Author: xiao321 1042460...@qq.com
Closes #3153 from xiao321/patch-1 and squashes the following commits:
0ed17b5 [xiao321] Update JavaCustomReceiver.java
(cherry picked from commit 7c9ec529a3483fab48f728481dd1d3663369e50a)
Signed-off-by: Tathagata Das tathagata.das1...@gmail.com
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4fb26df8
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4fb26df8
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4fb26df8
Branch: refs/heads/branch-1.1
Commit: 4fb26df8748ea7dda11db8c2b99f4b08da25bb4e
Parents: 0a40eac
Author: xiao321 1042460...@qq.com
Authored: Fri Nov 7 12:56:49 2014 -0800
Committer: Tathagata Das tathagata.das1...@gmail.com
Committed: Fri Nov 7 12:57:38 2014 -0800
--
.../org/apache/spark/examples/streaming/JavaCustomReceiver.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/spark/blob/4fb26df8/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
--
diff --git
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
index 5622df5..f92615d 100644
---
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
+++
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
@@ -70,7 +70,7 @@ public class JavaCustomReceiver extends ReceiverString {
// Create a input stream with the custom receiver on target ip:port and
count the
// words in input stream of \n delimited text (eg. generated by 'nc')
JavaReceiverInputDStreamString lines = ssc.receiverStream(
- new JavaCustomReceiver(args[1], Integer.parseInt(args[2])));
+ new JavaCustomReceiver(args[0], Integer.parseInt(args[1])));
JavaDStreamString words = lines.flatMap(new FlatMapFunctionString,
String() {
@Override
public IterableString call(String x) {
-
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: Update JavaCustomReceiver.java
Repository: spark
Updated Branches:
refs/heads/branch-1.0 76c20cac9 - 18c8c3833
Update JavaCustomReceiver.java
æ°ç»ä¸æ è¶ç
Author: xiao321 1042460...@qq.com
Closes #3153 from xiao321/patch-1 and squashes the following commits:
0ed17b5 [xiao321] Update JavaCustomReceiver.java
(cherry picked from commit 7c9ec529a3483fab48f728481dd1d3663369e50a)
Signed-off-by: Tathagata Das tathagata.das1...@gmail.com
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/18c8c383
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/18c8c383
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/18c8c383
Branch: refs/heads/branch-1.0
Commit: 18c8c3833d8508ff1ac1cf2c02060c41e46908c1
Parents: 76c20ca
Author: xiao321 1042460...@qq.com
Authored: Fri Nov 7 12:56:49 2014 -0800
Committer: Tathagata Das tathagata.das1...@gmail.com
Committed: Fri Nov 7 12:58:02 2014 -0800
--
.../org/apache/spark/examples/streaming/JavaCustomReceiver.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/spark/blob/18c8c383/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
--
diff --git
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
index 5622df5..f92615d 100644
---
a/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
+++
b/examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java
@@ -70,7 +70,7 @@ public class JavaCustomReceiver extends ReceiverString {
// Create a input stream with the custom receiver on target ip:port and
count the
// words in input stream of \n delimited text (eg. generated by 'nc')
JavaReceiverInputDStreamString lines = ssc.receiverStream(
- new JavaCustomReceiver(args[1], Integer.parseInt(args[2])));
+ new JavaCustomReceiver(args[0], Integer.parseInt(args[1])));
JavaDStreamString words = lines.flatMap(new FlatMapFunctionString,
String() {
@Override
public IterableString call(String x) {
-
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
