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 >> > >
