2014-03-14 3 views
1

Я пытаюсь использовать Apache Flume для сохранения твитов в HDFS. В настоящее время я использую изображение Cloudera с Hadoop и Flume. Я следил за учебником из блога Cloudera, но я не могу подключиться к API Twitter.Apache Flume подключение к twitter API 401: учетные данные аутентификации

Я получаю следующее сообщение об ошибке:

2014-03-14 09:43:14,021 INFO org.apache.flume.node.Application: Waiting for channel: MemChannel to start. Sleeping for 500 ms 
2014-03-14 09:43:14,069 INFO org.apache.flume.instrumentation.MonitoredCounterGroup: Monitored counter group for type: CHANNEL, name: MemChannel: Successfully registered new MBean. 
2014-03-14 09:43:14,069 INFO org.apache.flume.instrumentation.MonitoredCounterGroup: Component type: CHANNEL, name: MemChannel started 
2014-03-14 09:43:14,522 INFO org.apache.flume.node.Application: Starting Sink HDFS 
2014-03-14 09:43:14,522 INFO org.apache.flume.node.Application: Starting Source Twitter 
2014-03-14 09:43:14,525 INFO org.apache.flume.instrumentation.MonitoredCounterGroup: Monitored counter group for type: SINK, name: HDFS: Successfully registered new MBean. 
2014-03-14 09:43:14,525 INFO org.apache.flume.instrumentation.MonitoredCounterGroup: Component type: SINK, name: HDFS started 
2014-03-14 09:43:14,595 INFO twitter4j.TwitterStreamImpl: Establishing connection. 
2014-03-14 09:43:14,680 INFO org.mortbay.log: Logging to org.slf4j.impl.Log4jLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog 
2014-03-14 09:43:14,823 INFO org.mortbay.log: jetty-6.1.26 
2014-03-14 09:43:14,946 INFO org.mortbay.log: Started [email protected]:41414 
2014-03-14 09:43:16,249 INFO twitter4j.TwitterStreamImpl: 401:Authentication credentials (https://dev.twitter.com/pages/auth) were missing or incorrect. Ensure that you have set valid consumer key/secret, access token/secret, and the system clock is in sync. 

HTTP ERROR: 401 

Problem accessing '/1.1/statuses/filter.json'. Reason: 
Unauthorized 



2014-03-14 09:43:16,249 INFO twitter4j.TwitterStreamImpl: Waiting for 10000 milliseconds 
2014-03-14 09:43:26,251 INFO twitter4j.TwitterStreamImpl: Establishing 

Я скопировал мои документы твиттер API в flume.conf (я пробовал в обоих на диске и веб-интерфейс). Я также попытался восстановить их снова и скопировать эти новые, но это не помогло мне.

Мой pom.xml содержит:

<dependency> 
    <groupId>org.twitter4j</groupId> 
    <artifactId>twitter4j-stream</artifactId> 
    <version>3.0.5</version> 
</dependency> 

Это означает, что не должно быть проблемы, описанной here.

И я также установить системное время с помощью команды:

sudo ntpdate pool.ntp.org 

Кто-нибудь есть представление о том, что может быть возможно неправильно? Благодарим вас за любые предложения и помощь.

ответ

0

Try обновление до Twitter4J 3.0.6 .. я решил подобную проблему путем обновления до 3.0.6

+0

Я обновил для 3.0.6, но, к сожалению, я все еще получаю ту же ошибку. – ziky90

0

Update: Сво из-за недопустимого потребителя ключ/секретный, маркер доступа/секрет, и убедитесь, что есть системные часы синхронизированы ».

 Смежные вопросы

  • Нет связанных вопросов^_^