2017-11-25 29 views
0

ich einige Beispiel bin nach zu versuchen, die Distributed File unter Verwendung der folgenden zu bekommen, aber ich fand die folgenden Renditen Fehler veraltetWie erhält man DistributedFileSystem?

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

Exception in thread „main“ java.lang.ClassCastException: org.apache .hadoop.fs.LocalFileSystem können nicht Hadoop.File.infoNode (File.java:55) bei Hadoop.Driver.main (Driver.java:8) bei zu org.apache.hadoop.hdfs.DistributedFileSystem gegossen werden sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Methode) um sun.reflect.NativeMethodAccessorImpl.invok e (NativeMethodAccessorImpl.java:62) bei sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) bei java.lang.reflect.Method.invoke (Method.java:498)

Wie um das zu beheben? Diese

Antwort

0

ist kein Abschreibungs Fehler

Localfilesystem kann nicht

Ihr conf Objekt mit einem fs.defaultFS initialisiert werden muss gegossen werden, die mit hdfs:// beginnt statt file://

Schauen Sie sich die core-site.xml-Datei in Ihrem HADOOP_CONF_DIR, um die Eigenschaft

festzulegen 0