0

Twitter のデータが読み取り可能な形式ではありません。ハイブテーブルを使用して読み取ろうとしているflumeを使用してTwitterデータをフェッチしました。しかし、hdfs に適切なデータが表示されません。詳細は次のとおりです。

Flume-env.sh -

export JAVA_HOME=/usr/java/jdk1.7.0_67-cloudera
FLUME_CLASSPATH="/opt/cloudera/parcels/CDH-5.8.0-1.cdh5.8.0.p0.42/lib/flume-ng/lib/flume-sources-1.0-SNAPSHOT.jar

さえずり.conf -

    TwitterAgent.sources = Twitter
    TwitterAgent.channels = MemChannel
    TwitterAgent.sinks = HDFS

    TwitterAgent.sources.Twitter.type=org.apache.flume.source.twitter.TwitterSource
    TwitterAgent.sources.Twitter.channels = MemChannel
    TwitterAgent.sources.Twitter.consumerKey = xxxxxxxxxxxxxxxxxxxxxxxxx
    TwitterAgent.sources.Twitter.consumerSecret = xxxxxxxxxxxxxxxxxxxxxxxx
    TwitterAgent.sources.Twitter.accessToken = xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
    TwitterAgent.sources.Twitter.accessTokenSecret = xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx

    TwitterAgent.sources.Twitter.keywords = hadoop, bigdata, data science

    TwitterAgent.sinks.HDFS.channel = MemChannel
    TwitterAgent.sinks.HDFS.type = hdfs
    TwitterAgent.sinks.HDFS.hdfs.path = hdfs://opt:8020/user/flume/tweets
    TwitterAgent.sinks.HDFS.hdfs.fileType = DataStream
    TwitterAgent.sinks.HDFS.hdfs.writeFormat = Text
    TwitterAgent.sinks.HDFS.hdfs.batchSize = 100
    TwitterAgent.sinks.HDFS.hdfs.rollSize = 0
    TwitterAgent.sinks.HDFS.hdfs.rollCount = 100

    TwitterAgent.channels.MemChannel.type = memory
    TwitterAgent.channels.MemChannel.capacity = 100
    TwitterAgent.channels.MemChannel.transactionCapacity = 100

ファイルの1つを減らすと:

ここに画像の説明を入力

誰かが私が間違っているところを教えてもらえますか? ハイブテーブルの読み取り可能な形式でこのデータが必要です。

4

1 に答える 1

0

解決しました。TwitterAgent.sources.Twitter.type=org.apache.flume.source.twitter.TwitterSource を TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource に変更しました

于 2017-05-29T08:19:31.883 に答える