Re: NoClassDefFoundError when running Twitter Example

2018-07-24 Thread Till Rohrmann
Hi Syed, could you check whether this class is actually contained in the twitter example jar? If not, then you have to build an uber jar containing all required dependencies. Cheers, Till On Tue, Jul 24, 2018 at 5:11 AM syed wrote: > I am facing the *java.lang.NoClassDefFoundError: &g

NoClassDefFoundError when running Twitter Example

2018-07-23 Thread syed
I am facing the *java.lang.NoClassDefFoundError: com/twitter/hbc/httpclient/auth/Authentication* error when running the tweeter example. The example works well with the sample data, but I am unable to run it with real tweet data. Please guide me how to fix this issue. I am running Flink 1.3.2.

Re: Twitter example

2017-08-30 Thread Krishnanand Khambadkone
sender | Approve domain >>> Hi, >>> >>> print() writes the data to the out files of the TaskManagers. So you need >>> to go to the machine that runs the TM and check its out file which is >>> located in the log folder. >>> >>>

Re: Twitter example

2017-08-30 Thread Fabian Hueske
you need > to go to the machine that runs the TM and check its out file which is > located in the log folder. > > Best, Fabian > > 2017-08-29 23:53 GMT+02:00 Krishnanand Khambadkone <kkhambadk...@yahoo.com > >: > >> I am trying to run the basic twitter example, i

Re: Twitter example

2017-08-30 Thread Krishnanand Khambadkone
08-29 23:53 GMT+02:00 Krishnanand Khambadkone <kkhambadk...@yahoo.com>: >> I am trying to run the basic twitter example, it does deploy correctly and >> show as RUNNING both in the command line and in the UI. However I see no >> output. I am able to verify that my credent

Re: Twitter example

2017-08-30 Thread Fabian Hueske
ng to run the basic twitter example, it does deploy correctly > and show as RUNNING both in the command line and in the UI. However I see > no output. I am able to verify that my credentials are correct with > another small client I have built that does connect to twitter and p

Twitter example

2017-08-29 Thread Krishnanand Khambadkone
I am trying to run the basic twitter example,  it does deploy correctly and show as RUNNING both in the command line and in the UI.  However I see no output.  I am able to verify that my credentials are correct with another small client I have built that does connect to twitter and prints out

Re: Exception when trying to run flink twitter example

2017-08-22 Thread Krishnanand Khambadkone
Till,  Thank you for the prompt response.  Yes, including the build.properties (version = 2.2.0) made the exception go away.  Now no exception but no tweets output either.  The program just sits there doing nothing.  I have not specified an output directory so the tweets are sent to stdout.   

Re: Exception when trying to run flink twitter example

2017-08-22 Thread Till Rohrmann
Hi Krishnanand, could you check that you have the build.properties file in you fat jar containing the field version=? Cheers, Till On Tue, Aug 22, 2017 at 6:19 PM, Krishnanand Khambadkone < kkhambadk...@yahoo.com> wrote: > Hi, I have created a fat jar with my twitterexample classes and am >

Exception when trying to run flink twitter example

2017-08-22 Thread Krishnanand Khambadkone
Hi,  I have created a fat jar with my twitterexample classes and am running it like this,  ~/flink-1.3.2/build-target/bin/flink run -c TwitterExample ./flinktwitter.jar  --twitter-source.consumerKey --twitter-source.consumerSecret --twitter-source.token --twitter-source.tokenSecret I am

Re: IOException when trying flink-twitter example

2016-02-21 Thread ram kumar
tried running the TwitterFilterSourceExample as java application, works fine. facing issue when submitting as flink. looking into flink libraries On Wed, Feb 17, 2016 at 8:22 PM, Stephan Ewen wrote: > Looks like an issue with the Twitter Client. > > Maybe the log reveals more

Re: IOException when trying flink-twitter example

2016-02-17 Thread Stephan Ewen
Looks like an issue with the Twitter Client. Maybe the log reveals more that can help you figure out what is happening (loss of connection, etc). On Mon, Feb 15, 2016 at 1:32 PM, ram kumar wrote: > org.apache.flink.streaming.connectors.twitter.TwitterFilterSource - >

Re: IOException when trying flink-twitter example

2016-02-15 Thread ram kumar
org.apache.flink.streaming.connectors.twitter.TwitterFilterSource - Initializing Twitter Streaming API connection 12:27:32,134 INFO com.twitter.hbc.httpclient.BasicClient- New connection executed: twitterSourceClient, endpoint: /1.1/statuses/filter.json?delimited=length

IOException when trying flink-twitter example

2016-02-11 Thread ram kumar
Hi, Got following exception in taskmanager logs when running TwitterFilterSourceExample, 08:25:19,207 WARN com.twitter.hbc.httpclient.ClientBase - twitterSourceClient failed to establish connection properly 08:25:19,207 INFO com.twitter.hbc.httpclient.ClientBase