Hi!
Thanks for figuring this out.
Turns out that this issue was caused by a conflict between versions of the
Apache HTTP Components library used by the Twitter Client, and used by the
Hadoop/HDFS libraries.
>From version 1.0 on, we shade that library in Hadoop, so that issue should
be solved and
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
c
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 that can help you f
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 -
> Initializing Twitter Strea
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:
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 w
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
