diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-uploader/src/main/java/org/apache/hadoop/mapred/uploader/FrameworkUploader.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-uploader/src/main/java/org/apache/hadoop/mapred/uploader/FrameworkUploader.java index 3dea023ea7b..52ee38aaa93 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-uploader/src/main/java/org/apache/hadoop/mapred/uploader/FrameworkUploader.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-uploader/src/main/java/org/apache/hadoop/mapred/uploader/FrameworkUploader.java @@ -175,7 +175,6 @@ public class FrameworkUploader implements Runnable { @VisibleForTesting void beginUpload() throws IOException, UploaderException { if (targetStream == null) { - validateTargetPath(); int lastIndex = target.indexOf('#'); targetPath = new Path( @@ -480,13 +479,6 @@ public class FrameworkUploader implements Runnable { return false; } - private void validateTargetPath() throws UploaderException { - if (!target.startsWith("hdfs:/") && - !target.startsWith("file:/")) { - throw new UploaderException("Target path is not hdfs or local " + target); - } - } - @VisibleForTesting boolean parseArguments(String[] args) throws IOException { Options opts = new Options();