flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Igor Berman <igor.ber...@gmail.com>
Subject Re: IOException when trying flink-twitter example
Date Sun, 28 Feb 2016 10:46:28 GMT
http://stackoverflow.com/questions/32379590/ioexcpetion-while-connecting-to-twitter-streaming-api-with-apache-flink

there is a problem with http client,
I've solved it by downloading httpclient-4.2.6.jar jar into flink/lib and
renamed it to have "a" (ahttpclient-4.2.6.jar) so it will be added to
classpath of flink runtime first(by bin/config.sh)

On 21 February 2016 at 22:56, ram kumar <ramkumarrock3@gmail.com> wrote:

> 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 <sewen@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 <ramkumarrock3@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 <mxm@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 <ramkumarrock3@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
>>>>
>>>
>>>
>>
>

Mime
View raw message