twitter source is shutting down after successfull connect

Posted by Björn Ebbinghaus on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/twitter-source-is-shutting-down-after-successfull-connect-tp23114.html

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