diff options
| -rw-r--r-- | external/twitter/pom.xml | 2 | ||||
| -rw-r--r-- | external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/external/twitter/pom.xml b/external/twitter/pom.xml index 4c22ec8b3b..087270de90 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> 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() |