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

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

[1]: https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/twitter.html

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