2 vinvcr vinvcr 于 2016.05.09 11:08 提问

hive问题: pyhs2 load数据报错

Traceback (most recent call last):
File "hive_pyhs2.py", line 23, in
cur.execute("load data local inpath '/home/linqiaoying/e/hive/data/b.txt' overwrite into table student")
File "build/bdist.linux-x86_64/egg/pyhs2/cursor.py", line 64, in execute
pyhs2.error.Pyhs2Exception: 'Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.MoveTask'

#!/usr/bin/env python

-*- coding: utf-8 -*-

hive util with hive server2

import sys
import pyhs2
from setuptools import setup, Extension

with pyhs2.connect(host='127.0.0.1'',
port=10000,
authMechanism="PLAIN",
user='root',
password='rootroot',
database='default') as conn:
with conn.cursor() as cur:
print cur.getDatabases()

cur.execute("select * from tp_trade_order")
print cur.getSchema()
for i in cur.fetch():
    print i

cur.execute("load data local inpath '/home/linqiaoying/e/hive/data/b.txt' overwrite into table student")

cur.close()

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!