我试图在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代码中做些什么来处理这个问题吗?非常感谢你的帮助。
暂无答案!
目前还没有任何答案,快来回答吧!