2016-10-13 6 views
0

このログ情報を1日連続で取得しています。Flumeを設定してTwitterからHDFSにデータを収集する

2016年10月12日21:32:05696(CONFファイル・ポーラー-0)[デバッグ - org.apache.flume.node.PollingPropertiesFileConfigurationProvider $ FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:126)] コマンドを実行するときの変更点はconf/flume.confです。 FLUME_HOME/bin/flume-ngエージェント--conf ./conf/ -f conf/flume.conf -Dflume.root.logger = DEBUG、console - nはTwitterAgent

IAMがconfファイル

を変更した後、今、このエラーを取得します

2016年10月12日22:09:19592(lifecycleSupervisor-1-0)[デバッグ - com.cloudera.flume.source.TwitterSource.start(TwitterSource.java:124)] Twitterのサンプルストリームを設定しますコンシューマキーと アクセストークンを使用して2016-10-12 22:09:19,592 (ライフサイクルスーパーバイザー - 1-0)[ERROR - org.apache.flume.lifecycle.LifecycleSupervisor $ MonitorRunnable.run(LifecycleSupervisor.java:253)] EventDrivenSourceRunnerを開始できません:{ ソース:com.cloudera.flume.source.TwitterSource {名前:Twitter、状態:IDLE} } - 例外が続きます。 java.lang.IllegalStateException:コンシューマ キー/シークレットペアがすでに設定されています。

+0

あなたのflume.confと情報ログをシャーすることができます –

+0

はこれを試しました。http://stackoverflow.com/questions/29094499/getting-checking-flume-conf-for-changes-in-a-loop –

+0

私はあなたに郵送しましたエラー –

答えて

0

は、私の知る限り、あなたがここに提供したものから理解できるように、私はあなたがTwitterのAPIにアクセスするための資格情報を使用していることを確認してくださいまた、Twitterのソースを定義するには、あなたのconfファイルにa1.sources.r1.type = org.apache.flume.source.twitter.TwitterSourceを追加する必要があると思います。

+0

助けてくれてありがとう。 –

関連する問題