问题描述

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()