Tag: 蜂巢

PyHive Thrift传输exception：读取0个字节: 我想通过使用DB-API（asynchronous）示例通过python（PyHive 0.5，python 2.7）连接到Docker容器（从容器外）运行的Hive server-2 from pyhive import hive conn = hive.connect(host='172.17.0.2', port='10001', auth='NOSASL') 但是，我得到以下错误 Traceback (most recent call last): File "py_2.py", line 4, in <module> conn = hive.connect(host='172.17.0.2', port='10001', auth='NOSASL') File "/home/foodie/anaconda2/lib/python2.7/site-packages/pyhive/hive.py", line 64, in connect return Connection(*args, **kwargs) File "/home/foodie/anaconda2/lib/python2.7/site-packages/pyhive/hive.py", line 164, in __init__ response = self._client.OpenSession(open_session_req) File "/home/foodie/anaconda2/lib/python2.7/site-packages/TCLIService/TCLIService.py", line 187, in OpenSession return […]

Hue / Hive用户root不允许冒充Hue: 情况：我已经在不同的Docker容器中设置了Hive，Hue和Hadoop。在同一个Dockernetworking中。我为每个Hadoop Namenode，2个Datanodes，1个Hue实例，1个Hive Server和一个Postgres Metastore创build了一个容器。我能够在namenode的hdfs-site.xml中configurationhue代理用户，并且可以通过webhdfs浏览文件系统。然而，对于Hive，我得到了Hue中的错误： Failed to open new session: java.lang.RuntimeException: org.apache.hadoop.ipc.RemoteException (org.apache.hadoop.security.authorize.AuthorizationException): User: root is not allowed to impersonate hue 我可以在Hive中创buildHive表格，或者在Sparkjobs中写入Hive表格。我到目前为止所尝试的是：我试过添加类似的属性 hive.server2.proxy.user = hue hive.server2.enable.impersonation =真 hadoop.proxyuser.hue.hosts = * hive.server2.authentication = NONE 在不同的configuration文件中，如： core-site.xml在hdfs-namenodeconfiguration文件夹中 hive-hadoop文件夹中的core-site.xml 两者都是hdfs-site.xml hive-conf文件夹中的hive-site.xml 这个问题大部分都是在类似的问题上提出的，但是现在看起来并不是最新的。对于一些房产蜂房说：财产不明我需要澄清的是：什么是正确的文件添加configuration？什么是正确的财产补充？我是否必须添加一些configuration到色调的metaore？附加信息： – Hive版本：2.3.1 – Hive Hadoop版本：2.7.4 […]

将数据从主机加载到Dockerconfiguration单元容器: 我有一个csv文件在我的主机，我有一个docker虚拟机。我想从主机上的csvfile upload数据到虚拟机。我正在使用python的hive_service库连接并进行查询。然而，我坚持如何把数据放入虚拟机。例如，下面的脚本连接并能够查询configuration单元，但在第二个查询时失败。我需要从我的主机上传smpl.txt到docker vm import sys from hive_service import ThriftHive from hive_service.ttypes import HiveServerException from thrift import Thrift from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryProtocol try: print "1111" transport = TSocket.TSocket("192.168.99.100", 10000) transport = TTransport.TBufferedTransport(transport) protocol = TBinaryProtocol.TBinaryProtocol(transport) print "2222" client = ThriftHive.Client(protocol) transport.open() print "3333" […]