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 <se...@apache.org> wrote: > 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 <ramkumarro...@gmail.com> > wrote: > >> 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 >> 12:27:32,135 INFO >> org.apache.flink.streaming.connectors.twitter.TwitterFilterSource - >> Twitter Streaming API connection established successfully >> 12:27:32,233 INFO >> com.twitter.hbc.httpclient.ClientBase - >> twitterSourceClient Establishing a connection >> 12:27:32,296 WARN >> com.twitter.hbc.httpclient.ClientBase - >> twitterSourceClient IOException caught when establishing connection to >> https://stream.twitter.com/1.1/statuses/filter.json?delimited=length >> >> When i run the job, at first the connection is established, >> then this log appears >> >> 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 - >> twitterSourceClient Done processing, preparing to close connection >> 08:25:19,208 INFO >> com.twitter.hbc.httpclient.ClientBase - >> twitterSourceClient Establishing a connection >> 08:25:19,225 WARN >> com.twitter.hbc.httpclient.ClientBase - >> twitterSourceClient IOException caught when establishing connection to >> https://stream.twitter.com/1.1/statuses/filter.json?delimited=length >> >> >> On Thu, Feb 11, 2016 at 2:55 PM, Maximilian Michels <m...@apache.org> >> wrote: >> >>> Hi Ram, >>> >>> This is an Exception thrown in the Twitter client. Unfortunately the >>> exception is caught and not printed to the screen. >>> >>> I would suggest to set a breakpoint in the ClientBase to find out >>> about the reason for the failed connection. >>> >>> Cheers, >>> Max >>> >>> On Thu, Feb 11, 2016 at 9:30 AM, ram kumar <ramkumarro...@gmail.com> >>> wrote: >>> > 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 >>> > - twitterSourceClient Done processing, preparing to close connection >>> > 08:25:19,208 INFO com.twitter.hbc.httpclient.ClientBase >>> > - twitterSourceClient Establishing a connection >>> > 08:25:19,225 WARN com.twitter.hbc.httpclient.ClientBase >>> > - twitterSourceClient IOException caught when establishing connection >>> to >>> > https://stream.twitter.com/1.1/statuses/filter.json?delimited=length >>> > >>> > >>> > >>> > Anyone faced this same issue? >>> > >>> > Thanks >>> >> >> >
