1

我正在用 Hadoop 和 HBase 做一个测试项目。目前,该集群在一台 Windows 机器上托管了 2 个 Ubuntu 虚拟机。

我可以使用以下 HBase Java API 配置远程执行 PUT、QUERY 和 DELETE 操作(在我的主机中)

config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "192.168.56.90");  
config.set("hbase.zookeeper.property.clientPort", "2222");

当我尝试在 Windows 上使用与上述相同的配置运行 HBase MapReduce 作业时,出现以下错误

    13/03/24 06:11:03 ERROR security.UserGroupInformation: PriviledgedActionException as:Joel cause:java.io.IOException: Failed to set permissions of path: \tmp\hadoop-Joel\mapred\staging\Joel290889388\.staging to 0700
java.io.IOException: Failed to set permissions of path: \tmp\hadoop-Joel\mapred\staging\Joel290889388\.staging to 0700 

从我在网上阅读的内容来看,在 Windows 上运行 MapReduce 作业似乎存在问题。所以我尝试使用“java - jar MR.jar”在 Linux 上运行 MapReduce 作业。

在 Linux 上,我无法连接到 Zookeeper。由于未知原因,Zookeeper 主机和端口正在客户端重置

13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Client environment:os.version=3.5.0-23-generic
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Client environment:user.name=hduser
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Client environment:user.home=/home/hduser
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Client environment:user.dir=/home/hduser/testes
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=192.168.56.90:2222 sessionTimeout=180000 watcher=hconnection
13/03/24 05:59:33 INFO zookeeper.RecoverableZooKeeper: The identifier of this process is 11552@node01
13/03/24 05:59:33 INFO zookeeper.ClientCnxn: Opening socket connection to server node01/192.168.56.90:2222. Will not attempt to authenticate using SASL (unknown error)
13/03/24 05:59:33 INFO zookeeper.ClientCnxn: Socket connection established to node01/192.168.56.90:2222, initiating session
13/03/24 05:59:33 INFO zookeeper.ClientCnxn: Session establishment complete on server node01/192.168.56.90:2222, sessionid = 0x13d9afaa1a30006, negotiated timeout = 180000
13/03/24 05:59:33 INFO client.HConnectionManager$HConnectionImplementation: Closed zookeeper sessionid=0x13d9afaa1a30006
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Session: 0x13d9afaa1a30006 closed
13/03/24 05:59:33 INFO zookeeper.ClientCnxn: EventThread shut down
13/03/24 05:59:33 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
13/03/24 05:59:33 WARN mapred.JobClient: Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same.
13/03/24 05:59:33 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=localhost:2181 sessionTimeout=180000 watcher=hconnection
13/03/24 05:59:33 INFO zookeeper.RecoverableZooKeeper: The identifier of this process is 11552@node01
13/03/24 05:59:33 INFO zookeeper.ClientCnxn: Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
13/03/24 05:59:33 WARN zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:692)
        at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)

从上面的日志来看,正确连接到node01:2222(node01解析为192.168.56.90)。但是由于某种原因,它更改为 localhost:2181 然后它给出了一个连接被拒绝的错误。

如何解决这个问题,让 MR 作业在 Linux 上运行,与 Zookeeper 运行在同一台机器上?

版本:Hbase 0.94.5 / Hadoop 1.1.2

谢谢。

4

1 回答 1

1

您可能还需要设置 hbase.master。

还要检查 /etc/hosts 文件,看看它是否正确。您是否能够使用该连接信息远程登录到动物园管理员?

config.set("hbase.zookeeper.quorum", "192.168.56.90");  
config.set("hbase.zookeeper.property.clientPort", "2222");
config.set("hbase.master", "some.host.com:60000")
于 2013-03-28T21:19:10.963 回答