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 >
