You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2016/06/10 15:23:48 UTC
[09/50] [abbrv] bahir git commit: [SPARK-11245] update twitter4j to
4.0.4 version
[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/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/3b1cc918
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/3b1cc918
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/3b1cc918
Branch: refs/heads/master
Commit: 3b1cc918d9e17ad45ed9b8610a0ab2007c3c0018
Parents: c03f462
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
----------------------------------------------------------------------
streaming-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/bahir/blob/3b1cc918/streaming-twitter/pom.xml
----------------------------------------------------------------------
diff --git a/streaming-twitter/pom.xml b/streaming-twitter/pom.xml
index 4c22ec8..087270d 100644
--- a/streaming-twitter/pom.xml
+++ b/streaming-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/bahir/blob/3b1cc918/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
----------------------------------------------------------------------
diff --git a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala b/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
index d7de74b..9a85a65 100644
--- a/streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
+++ b/streaming-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()