2017-11-25 91 views
0

我下面一些例子來嘗試使用以下,以獲得DistributedFileSystem,但是我發現下面的返回廢棄的錯誤如何獲得DistributedFileSystem?

FileSystem fs=FileSystem.get(conf); 
DistributedFileSystem hdfs = (DistributedFileSystem) fs; 

異常在線程「主要」 java.lang.ClassCastException: org.apache .hadoop.fs.LocalFileSystem不能在 在 Hadoop.Driver.main(Driver.java:8)投射到 org.apache.hadoop.hdfs.DistributedFileSystem在 Hadoop.File.infoNode(File.java:55) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invok E(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在java.lang.reflect.Method.invoke(Method.java:498)

如何解決這個問題?

回答

0

這不是貶值錯誤

LocalFileSystem無法施展

conf對象需要被初始化爲fs.defaultFS,隨着hdfs://代替file://

退房的開始您的HADOOP_CONF_DIR中的core-site.xml文件設置屬性