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