在aws中部署自定义jar在线程“main”java.lang.illegalargumentexception中失败异常:错误的fs

xqkwcwgp  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(133)

我试图在aws(map reduce)中部署一个定制的jar。我要读s3的文件。s3的路径作为命令行参数给出。在群集运行时,我在群集的“步骤”部分看到以下内容:

Status:FAILED
Reason:Illegal Argument.
Log File:s3://aws-logs-502743756123-us-east-1/elasticmapreduce/j-3U1NGY5JNUBK2/steps/s-O3W3I4RU4NXS/stderr.gz
Details:Exception in thread "main" java.lang.IllegalArgumentException: Wrong FS: s3n://****/input, expected: hdfs://ip-172-31-45-130.ec2.internal:8020
JAR location: s3://****/ChainMapperDriver.jar
Main class: None
Arguments: ChainMapperDriver s3://****/input s3://****/output/
Action on failure: Terminate cluster

chainmapperdriver是主类的名称。
当文件在s3中时,我需要在我编写的java代码中做些什么来处理这个问题吗?非常感谢你的帮助。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题