You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by td...@apache.org on 2014/11/07 21:56:54 UTC
spark git commit: Update JavaCustomReceiver.java
Repository: spark
Updated Branches:
refs/heads/master d6e555244 -> 7c9ec529a
Update JavaCustomReceiver.java
数组下标越界
Author: xiao321 <10...@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 <10...@qq.com>
Authored: Fri Nov 7 12:56:49 2014 -0800
Committer: Tathagata Das <ta...@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 Receiver<String> {
// 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')
JavaReceiverInputDStream<String> lines = ssc.receiverStream(
- new JavaCustomReceiver(args[1], Integer.parseInt(args[2])));
+ new JavaCustomReceiver(args[0], Integer.parseInt(args[1])));
JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String, String>() {
@Override
public Iterable<String> call(String x) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org