Repository: spark Updated Branches: refs/heads/master ffed00493 -> e5bc8c275
[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.serv...@gmail.com> Closes #9221 from pronix/twitter4j_update. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e5bc8c27 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e5bc8c27 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e5bc8c27 Branch: refs/heads/master Commit: e5bc8c27577f96c1ae5dc8cf9bf41cbe2877ffe3 Parents: ffed004 Author: dima <pronix.serv...@gmail.com> Authored: Sat Oct 24 18:16:45 2015 +0100 Committer: Sean Owen <so...@cloudera.com> Committed: Sat Oct 24 18:16:45 2015 +0100 ---------------------------------------------------------------------- external/twitter/pom.xml | 2 +- .../org/apache/spark/streaming/twitter/TwitterInputDStream.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/e5bc8c27/external/twitter/pom.xml ---------------------------------------------------------------------- diff --git a/external/twitter/pom.xml b/external/twitter/pom.xml index 4c22ec8..087270d 100644 --- a/external/twitter/pom.xml +++ b/external/twitter/pom.xml @@ -51,7 +51,7 @@ <dependency> <groupId>org.twitter4j</groupId> <artifactId>twitter4j-stream</artifactId> - <version>3.0.3</version> + <version>4.0.4</version> </dependency> <dependency> <groupId>org.scalacheck</groupId> http://git-wip-us.apache.org/repos/asf/spark/blob/e5bc8c27/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala ---------------------------------------------------------------------- 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 d7de74b..9a85a65 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() --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org