Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-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 985BE18267 for ; Wed, 23 Sep 2015 11:27:59 +0000 (UTC) Received: (qmail 24420 invoked by uid 500); 23 Sep 2015 11:27:54 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 24339 invoked by uid 500); 23 Sep 2015 11:27:54 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 24328 invoked by uid 99); 23 Sep 2015 11:27:54 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 Sep 2015 11:27:54 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id F270AC0FAC for ; Wed, 23 Sep 2015 11:27:53 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.001 X-Spam-Level: * X-Spam-Status: No, score=1.001 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id kydvzM2VLNqS for ; Wed, 23 Sep 2015 11:27:45 +0000 (UTC) Received: from outpost1.zedat.fu-berlin.de (outpost1.zedat.fu-berlin.de [130.133.4.66]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 2DEE225DB9 for ; Wed, 23 Sep 2015 11:27:10 +0000 (UTC) Received: from inpost2.zedat.fu-berlin.de ([130.133.4.69]) by outpost.zedat.fu-berlin.de (Exim 4.85) for user@flink.apache.org with esmtp (envelope-from ) id <1ZeiCV-0020PU-Qd>; Wed, 23 Sep 2015 13:27:03 +0200 Received: from ip5b40315a.dynamic.kabel-deutschland.de ([91.64.49.90] helo=[192.168.178.69]) by inpost2.zedat.fu-berlin.de (Exim 4.85) for user@flink.apache.org with esmtpsa (envelope-from ) id <1ZeiCV-002TtK-Kp>; Wed, 23 Sep 2015 13:27:03 +0200 Content-Type: text/plain; charset=utf-8 Mime-Version: 1.0 (Mac OS X Mail 8.2 \(2104\)) Subject: Re: no valid hadoop home directory can be found From: Ufuk Celebi In-Reply-To: Date: Wed, 23 Sep 2015 13:27:01 +0200 Content-Transfer-Encoding: quoted-printable Message-Id: <3105A4D5-FC17-4B08-982E-C2C6754C8577@apache.org> References: To: user@flink.apache.org X-Mailer: Apple Mail (2.2104) X-Originating-IP: 91.64.49.90 Either specify the env variable HADOOP_HOME or set the JVM property = =E2=80=98hadoop.home.dir=E2=80=99 (-Dhadoop.home.dir=3D=E2=80=A6) =E2=80=93 Ufuk > On 23 Sep 2015, at 12:43, Lydia Ickler = wrote: >=20 > Hi all, >=20 > I get the following error message that no valid hadoop home directory = can be found when trying to initialize the HBase configuration. > Where would I specify that path? >=20 > 12:41:02,043 INFO org.apache.flink.addons.hbase.TableInputFormat = - Initializing HBaseConfiguration > 12:41:02,174 DEBUG org.apache.hadoop.util.Shell = - Failed to detect a valid hadoop home directory > java.io.IOException: HADOOP_HOME or hadoop.home.dir are not set. > at = org.apache.hadoop.util.Shell.checkHadoopHome(Shell.java:225) > at org.apache.hadoop.util.Shell.(Shell.java:250) > at = org.apache.hadoop.util.StringUtils.(StringUtils.java:76) > at = org.apache.hadoop.conf.Configuration.getStrings(Configuration.java:1514) > at = org.apache.hadoop.hbase.zookeeper.ZKConfig.makeZKProps(ZKConfig.java:113) > at = org.apache.hadoop.hbase.zookeeper.ZKConfig.getZKQuorumServersString(ZKConf= ig.java:259) > at = org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.(ZooKeeperWatcher= .java:159) > at = org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.(ZooKeeperWatcher= .java:134) > at = org.apache.hadoop.hbase.client.ZooKeeperKeepAliveConnection.(ZooKeep= erKeepAliveConnection.java:43) > at = org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementatio= n.getKeepAliveZooKeeperWatcher(HConnectionManager.java:1816) > at = org.apache.hadoop.hbase.client.ZooKeeperRegistry.getClusterId(ZooKeeperReg= istry.java:82) > at = org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementatio= n.retrieveClusterId(HConnectionManager.java:907) > at = org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementatio= n.(HConnectionManager.java:701) > at = sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) > at = sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAcc= essorImpl.java:62) > at = sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstr= uctorAccessorImpl.java:45) > at = java.lang.reflect.Constructor.newInstance(Constructor.java:408) > at = org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnec= tionManager.java:457) > at = org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnec= tionManager.java:436) > at = org.apache.hadoop.hbase.client.HConnectionManager.getConnection(HConnectio= nManager.java:317) > at = org.apache.hadoop.hbase.client.HTable.(HTable.java:198) > at = org.apache.hadoop.hbase.client.HTable.(HTable.java:160) > at = org.apache.flink.addons.hbase.TableInputFormat.createTable(TableInputForma= t.java:89) > at = org.apache.flink.addons.hbase.TableInputFormat.configure(TableInputFormat.= java:78) > at = org.apache.flink.runtime.operators.DataSourceTask.initInputFormat(DataSour= ceTask.java:273) > at = org.apache.flink.runtime.operators.DataSourceTask.registerInputOutput(Data= SourceTask.java:79) > at = org.apache.flink.runtime.taskmanager.Task.run(Task.java:501) > at java.lang.Thread.run(Thread.java:745) >=20