twitter source is shutting down after successfull connect

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

twitter source is shutting down after successfull connect

Björn Ebbinghaus
Hey,

I updated to flink-connector-twitter_2.11 version 1.6.0 
and now I am getting this error on startup. 
Used the 1.2.0 version before where everything worked. 
Any idea what is causing this?

17:39:07,866 INFO  com.twitter.hbc.httpclient.BasicClient                        - New connection executed: flink-twitter-source, endpoint: /1.1/statuses/sample.json
17:39:07,866 INFO  org.apache.flink.streaming.connectors.twitter.TwitterSource   - Twitter Streaming API connection established successfully
17:39:07,901 WARN  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source Uncaught exception
java.lang.NullPointerException
at org.apache.http.client.utils.URLEncodedUtils.parse(URLEncodedUtils.java:235)
at com.twitter.hbc.httpclient.auth.OAuth1.signRequest(OAuth1.java:71)
at com.twitter.hbc.core.HttpConstants.constructRequest(HttpConstants.java:75)
at com.twitter.hbc.httpclient.ClientBase.run(ClientBase.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
17:39:07,906 INFO  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source exit event - null
17:39:07,906 INFO  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source Shutting down httpclient connection manager

regards,

Björn
Reply | Threaded
Open this post in threaded view
|

Re: twitter source is shutting down after successfull connect

vino yang
Hi Björn,

From the exception stack information, the NPE comes from the auth module of the twitter client. 
Did you fill in the relevant authentication information correctly? 
Specific instructions can refer to the official guidance document.[1]

Thanks, vino.


Björn Ebbinghaus <[hidden email]> 于2018年9月16日周日 下午11:43写道:
Hey,

I updated to flink-connector-twitter_2.11 version 1.6.0 
and now I am getting this error on startup. 
Used the 1.2.0 version before where everything worked. 
Any idea what is causing this?

17:39:07,866 INFO  com.twitter.hbc.httpclient.BasicClient                        - New connection executed: flink-twitter-source, endpoint: /1.1/statuses/sample.json
17:39:07,866 INFO  org.apache.flink.streaming.connectors.twitter.TwitterSource   - Twitter Streaming API connection established successfully
17:39:07,901 WARN  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source Uncaught exception
java.lang.NullPointerException
at org.apache.http.client.utils.URLEncodedUtils.parse(URLEncodedUtils.java:235)
at com.twitter.hbc.httpclient.auth.OAuth1.signRequest(OAuth1.java:71)
at com.twitter.hbc.core.HttpConstants.constructRequest(HttpConstants.java:75)
at com.twitter.hbc.httpclient.ClientBase.run(ClientBase.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
17:39:07,906 INFO  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source exit event - null
17:39:07,906 INFO  com.twitter.hbc.httpclient.ClientBase                         - flink-twitter-source Shutting down httpclient connection manager

regards,

Björn