diff options
| author | xiao321 <1042460381@qq.com> | 2014-11-07 12:56:49 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-11-07 12:57:17 -0800 |
| commit | 8cefb63c122e7c7cf4af959f9606f4491148d9f4 (patch) | |
| tree | 678a2bcdefc479da2bc9c47f0c097e1d9a40da68 /examples/src/main | |
| parent | 47bd8f3020149a009f605e8390c2c28f3f835191 (diff) | |
| download | spark-8cefb63c122e7c7cf4af959f9606f4491148d9f4.tar.gz spark-8cefb63c122e7c7cf4af959f9606f4491148d9f4.tar.bz2 spark-8cefb63c122e7c7cf4af959f9606f4491148d9f4.zip | |
Update JavaCustomReceiver.java
数组下标越界
Author: xiao321 <1042460381@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.das1565@gmail.com>
Diffstat (limited to 'examples/src/main')
| -rw-r--r-- | examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java | 2 |
1 files changed, 1 insertions, 1 deletions
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 981bc4f061..99df259b4e 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) { |