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

回答

相關問題