0

我用命令在 hadoop 上运行水槽

flume-ng agent -c conf -f conf/flume-twitter.conf -n TwitterAgent

现在我无法保存推特数据。它显示错误。我在下面发布了错误。你有什么想法吗？？

    2016-01-29 15:48:56,979 (Twitter4J Async Dispatcher[0]) [DEBUG - com.cloudera.flume.source.TwitterSource$1.onStatus(TwitterSource.java:108)] ArtistLR: RT Ar
    tsUK1 An unlikely duo: Homeland's Nina Hoss plots with art joker Christian Janko

wski #Arts https://t.co/hJyClDCgk0
    2016-01-29 15:48:57,136 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.flume.sink.hdfs.BucketWriter.open(BucketWriter.java:234)] Creatin
    g hdfs://l27.0.0.1:9000/tweets/movies/2016/01/29/15//FlumeData.1454062721600.tmp
    2016-01-29 15:48:57,139 (SinkRunner-PollingRunner-DefaultSinkProcessor) [WARN - org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:455)] HD
    FS IO error
    java.io.IOException: Incomplete HDFS URI, no host: hdfs://l27.0.0.1:9000/tweets/movies/2016/01/29/15/FlumeData.1454062721600.tmp
            at org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:136)
            at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2591)
            at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:89)
            at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2625)
            at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2607)
            at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:368)
            at org.apache.hadoop.fs.Path.getFileSystem(Path.java:296)
            at org.apache.flume.sink.hdfs.BucketWriter$1.call(BucketWriter.java:243)
            at org.apache.flume.sink.hdfs.BucketWriter$1.call(BucketWriter.java:235)
            at org.apache.flume.sink.hdfs.BucketWriter$9$1.run(BucketWriter.java:679)
            at org.apache.flume.auth.SimpleAuthenticator.execute(SimpleAuthenticator.java:50)
            at org.apache.flume.sink.hdfs.BucketWriter$9.call(BucketWriter.java:676)
            at java.util.concurrent.FutureTask.run(FutureTask.java:262)
            at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
            at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
            at java.lang.Thread.run(Thread.java:745)
    2016-01-29 15:48:57,334 (agent-shutdown-hook) [INFO - org.apache.flume.lifecycle.LifecycleSupervisor.stop(LifecycleSupervisor.java:79)] Stopping lifecycle s
    upervisor 11
4

1 回答 1

1

仔细查看 URL：l27.0.0.1有一个小 L 而不是数字 1。配置中的错字？

于 2016-01-29T12:17:14.557 回答