spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From prabeesh k <prabsma...@gmail.com>
Subject Re: spark-0.8.0 Twitter examples showing errors
Date Wed, 02 Oct 2013 06:59:41 GMT
I am able to run the twitter examples after editing the code

   System.setProperty("twitter4j.oauth.consumerKey",
"WFpKfkM9.......................")
   System.setProperty("twitter4j.oauth.consumerSecret",
"4ADs7bPYBmQ28eD....................")
   System.setProperty("twitter4j.oauth.accessToken",
"60585063-8nXCy2.......................")
   System.setProperty("twitter4j.oauth.accessTokenSecret",
"L9ZgrqhH.............................")

Please include in twitter examples, specifying how to run the twitter
example


On Wed, Oct 2, 2013 at 11:54 AM, prabeesh k <prabsmails@gmail.com> wrote:

> No I am just trying to run the examples bundle with spark-0.8.0 from spark
> root folder as
>      ./run-example org.apache.spark.streaming.examples.TwitterAlgebirdHLL
> local[2] filters
>
>
>
>
>
> On Wed, Oct 2, 2013 at 11:30 AM, Stoney Vintson <stoneyv@gmail.com> wrote:
>
>> Are you using the streaming example from Amp Camp 3?
>>
>> http://ampcamp.berkeley.edu/3/exercises/realtime-processing-with-spark-streaming.html
>>
>> On Tue, Oct 1, 2013 at 10:36 PM, prabeesh k <prabsmails@gmail.com> wrote:
>> > Hi all,
>> >
>> > While running twitter examples  I am getting following errors
>> >    ERROR dstream.TwitterReceiver: Error receiving data
>> > java.lang.IllegalStateException: Authentication credentials are
>> missing. See
>> > http://twitter4j.org/configuration.html for the detail.
>> > at
>> >
>> twitter4j.TwitterBaseImpl.ensureAuthorizationEnabled(TwitterBaseImpl.java:200)
>> > at twitter4j.TwitterStreamImpl.filter(TwitterStreamImpl.java:287)
>> > at
>> >
>> org.apache.spark.streaming.dstream.TwitterReceiver.onStart(TwitterInputDStream.scala:87)
>> > at
>> >
>> org.apache.spark.streaming.dstream.NetworkReceiver.start(NetworkInputDStream.scala:125)
>> > at
>> >
>> org.apache.spark.streaming.NetworkInputTracker$ReceiverExecutor$$anonfun$8.apply(NetworkInputTracker.scala:157)
>> > at
>> >
>> org.apache.spark.streaming.NetworkInputTracker$ReceiverExecutor$$anonfun$8.apply(NetworkInputTracker.scala:153)
>> > at
>> >
>> org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:758)
>> > at
>> >
>> org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:758)
>> > at org.apache.spark.scheduler.ResultTask.run(ResultTask.scala:99)
>> > at
>> >
>> org.apache.spark.scheduler.local.LocalScheduler.runTask(LocalScheduler.scala:198)
>> > at
>> >
>> org.apache.spark.scheduler.local.LocalActor$$anonfun$launchTask$1$$anon$1.run(LocalScheduler.scala:68)
>> > at
>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>> > at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
>> > at java.util.concurrent.FutureTask.run(FutureTask.java:166)
>> > at
>> >
>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>> > at
>> >
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>> > at java.lang.Thread.run(Thread.java:722)
>> >
>> >
>> >
>> > Twitter streaming examples doesn't work now. Is this because Twitter API
>> > update ?
>> >
>> > https://dev.twitter.com/blog/api-v1-is-retired
>> >
>> > "Retirement of deprecated API v1.0. Retirement of Basic Auth support on
>> > Streaming API."
>> >
>> > https://dev.twitter.com/calendar
>> >
>> > Please update spark streaming module to access the twitter.
>>
>
>

Mime
View raw message