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 <bjoern....@gmail.com> 于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 >
