Return-Path: X-Original-To: apmail-hadoop-hdfs-user-archive@minotaur.apache.org Delivered-To: apmail-hadoop-hdfs-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E49E417E5D for ; Tue, 24 Feb 2015 18:57:59 +0000 (UTC) Received: (qmail 87540 invoked by uid 500); 24 Feb 2015 18:57:49 -0000 Delivered-To: apmail-hadoop-hdfs-user-archive@hadoop.apache.org Received: (qmail 87404 invoked by uid 500); 24 Feb 2015 18:57:49 -0000 Mailing-List: contact user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@hadoop.apache.org Delivered-To: mailing list user@hadoop.apache.org Received: (qmail 87385 invoked by uid 99); 24 Feb 2015 18:57:49 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 24 Feb 2015 18:57:49 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of xeonmailinglist@gmail.com designates 74.125.82.171 as permitted sender) Received: from [74.125.82.171] (HELO mail-we0-f171.google.com) (74.125.82.171) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 24 Feb 2015 18:57:43 +0000 Received: by wevm14 with SMTP id m14so27126057wev.8 for ; Tue, 24 Feb 2015 10:57:22 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=message-id:date:from:user-agent:mime-version:to:subject :content-type; bh=KwUYxA4qYXayOUIEAhAw7RxddG23Fl3CzyyMTGVZWAQ=; b=Mp3/1c5uou9kUVkN/yycQNUjgku+TLk4xgolJQfenZSf4+RocyVjfVJ9FYr4p/QDbS SgQ0puUQvulro8l+idMzvLN598McrSpR1uWKXN5hLMDYUV5IfZtDP2i+1qV2jJDIq2cp c+t4ImQjcg3+2kJkjb1NDcsM9+FXQ64BrXFghpKDsjdPy8getAmdEJxZrq9MFDpoJoVC fQXDkAmlpWQumnjBB4krzXc+XTIKE3Uqbu2vJmTC/F4ZKWXuJlBCFysFJHu8LTNuIa3U x1agI2dQNgKPqtrDEZjeX+L018d9zJyU31IQ4CgJFL+NNOvj0h7c/gjzMZFdEf0CYTV3 LplQ== X-Received: by 10.194.158.39 with SMTP id wr7mr36018996wjb.118.1424804242741; Tue, 24 Feb 2015 10:57:22 -0800 (PST) Received: from [10.10.5.115] ([194.117.22.6]) by mx.google.com with ESMTPSA id mb20sm21735432wic.18.2015.02.24.10.57.21 for (version=TLSv1.2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Tue, 24 Feb 2015 10:57:22 -0800 (PST) Message-ID: <54ECC991.1060702@gmail.com> Date: Tue, 24 Feb 2015 18:57:21 +0000 From: xeonmailinglist User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:31.0) Gecko/20100101 Thunderbird/31.4.0 MIME-Version: 1.0 To: user@hadoop.apache.org Subject: "No FileSystem for scheme: hdfs" when submitting a remote job Content-Type: multipart/alternative; boundary="------------000709030004030000060703" X-Virus-Checked: Checked by ClamAV on apache.org This is a multi-part message in MIME format. --------------000709030004030000060703 Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 8bit Hi, I am trying to submit a remote mapreduce job in Yarn with the configuration below, but I get the error |No FileSystem for scheme: hdfs|. The error is so also below. Why this is happening? | String host = "192.168.56.100"; Configuration conf = job.getConfiguration(); // this should be like defined in your yarn-site.xml conf.set("yarn.resourcemanager.address", host + ":50001"); // framework is now "yarn", should be defined like this in mapred-site.xm conf.set("mapreduce.framework.name", "yarn"); // like defined in hdfs-site.xml conf.set("fs.defaultFS", "hdfs://" + host + ":9000"); for (Path inputPath : inputPaths) FileInputFormat.addInputPath(job, new Path(conf.get("fs.defaultFS") + "/" + inputPath.toString())); FileOutputFormat.setOutputPath(job, new Path(conf.get("fs.defaultFS") + "/" + tempPath)); job.waitForCompletion(true); | |Exception in thread "main" java.io.IOException: No FileSystem for scheme: hdfs at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2584) at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2591) at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:91) at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2630) at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2612) at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:370) at org.apache.hadoop.fs.Path.getFileSystem(Path.java:296) at org.apache.hadoop.mapreduce.lib.input.FileInputFormat.addInputPath(FileInputFormat.java:518) at org.apache.hadoop.mapred.examples.JobExecution.submit(JobExecution.java:169) at org.apache.hadoop.mapred.examples.WordCount.main(WordCount.java:101) | Thanks, ​ --------------000709030004030000060703 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: 8bit

Hi,

I am trying to submit a remote mapreduce job in Yarn with the configuration below, but I get the error No FileSystem for scheme: hdfs. The error is so also below. Why this is happening?

         String host = "192.168.56.100";

           Configuration conf = job.getConfiguration();
           // this should be like defined in your yarn-site.xml
           conf.set("yarn.resourcemanager.address", host + ":50001"); 

            // framework is now "yarn", should be defined like this in mapred-site.xm
            conf.set("mapreduce.framework.name", "yarn");

            // like defined in hdfs-site.xml
            conf.set("fs.defaultFS", "hdfs://" + host + ":9000");

            for (Path inputPath : inputPaths)
                FileInputFormat.addInputPath(job, new Path(conf.get("fs.defaultFS") + "/" + inputPath.toString()));

            FileOutputFormat.setOutputPath(job, new Path(conf.get("fs.defaultFS") + "/" + tempPath));

            job.waitForCompletion(true);
Exception in thread "main" java.io.IOException: No FileSystem for scheme: hdfs
    at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2584)
    at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2591)
    at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:91)
    at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2630)
    at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2612)
    at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:370)
    at org.apache.hadoop.fs.Path.getFileSystem(Path.java:296)
    at org.apache.hadoop.mapreduce.lib.input.FileInputFormat.addInputPath(FileInputFormat.java:518)
    at org.apache.hadoop.mapred.examples.JobExecution.submit(JobExecution.java:169)
    at org.apache.hadoop.mapred.examples.WordCount.main(WordCount.java:101)

Thanks,

--------------000709030004030000060703--