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
