HDFS误差+不完全的HDFS URI，没有主持人：HDFS：//l27.0.0.1：9000

我在Hadoop运行水槽用命令HDFS误差+不完全的HDFS URI，没有主持人：HDFS：//l27.0.0.1：9000

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

，现在我不能够保存Twitter资料。它显示错误。我发布了下面的错误。你有什么想法吗？

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

来源

2016-01-29 srk

仔细查看网址：l27.0.0.1有一个小大号，而不是第1位配置中的错字？

来源

2016-01-29 12:17:14

它的1不小L – srk

它*应*是1.我同意。但你粘贴的堆栈跟踪肯定有小L. –

HDFS误差+不完全的HDFS URI，没有主持人：HDFS：//l27.0.0.1：9000

回答

相关问题