diff options
| author | dima <pronix.service@gmail.com> | 2015-10-24 18:16:45 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-10-24 18:16:45 +0100 |
| commit | e5bc8c27577f96c1ae5dc8cf9bf41cbe2877ffe3 (patch) | |
| tree | 604671921af06c5b3eac9e62cf026b09ea9c3949 /external/twitter/src | |
| parent | ffed00493a0aa2373a04e3aa374404936fbe15c7 (diff) | |
| download | spark-e5bc8c27577f96c1ae5dc8cf9bf41cbe2877ffe3.tar.gz spark-e5bc8c27577f96c1ae5dc8cf9bf41cbe2877ffe3.tar.bz2 spark-e5bc8c27577f96c1ae5dc8cf9bf41cbe2877ffe3.zip | |
[SPARK-11245] update twitter4j to 4.0.4 version
update twitter4j to 4.0.4 version
https://issues.apache.org/jira/browse/SPARK-11245
Author: dima <pronix.service@gmail.com>
Closes #9221 from pronix/twitter4j_update.
Diffstat (limited to 'external/twitter/src')
| -rw-r--r-- | external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala b/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala index d7de74b350..9a85a6597c 100644 --- a/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala +++ b/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala @@ -87,7 +87,7 @@ class TwitterReceiver( val query = new FilterQuery if (filters.size > 0) { - query.track(filters.toArray) + query.track(filters.mkString(",")) newTwitterStream.filter(query) } else { newTwitterStream.sample() |