You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/10/24 19:16:50 UTC

spark git commit: [SPARK-11245] update twitter4j to 4.0.4 version

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 <pr...@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 <pr...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org