hadoop—在java中尝试从hdfs复制fromlocalfile时,“错误的fs…应为:file:///”

nkhmeac6  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(386)

我试图通过下面的代码将.json从port/example\u file/2017复制到hdfs中的另一个位置/port/example\u file/2018

String exampleFile= "hdfs://port/example_File/2017/abc.json"
String targetFile="hdfs://port/example_File/2018"
hdfs.copyFromLocalFile(new Path(exampleFile),new Path(targetFile))

我的情况越来越糟了

org.jboss.resteasy.spi.UnhandledException: 
java.lang.IllegalArgumentException: Wrong FS:
 hdfs://port/example_File/2017/abc.json, expected: file:///

如何在hdfs中将文件从一个位置复制到另一个位置
谢谢,

mf98qq94

mf98qq941#

copyFromLocal 将文件从本地文件系统复制到hdfs。
要复制hdfs集群中的文件,请使用 FileUtil.copy() 并为两者指定相同的文件系统 srcFS 以及 dstFs .
使用 DistCp 在一个hdfs集群内或两个不同的hdfs集群之间复制大量文件时。请参阅这里的distcp java api。

相关问题