使用以下python脚本通过配置单元查询cosmos:
import pyhs2
with pyhs2.connect(host='cosmos.lab.fiware.org',
port=10000,
authMechanism="PLAIN",
user='glaquidara',
password='*****',
database='default') as conn:
with conn.cursor() as cur:
cur.execute("select * from glaquidara_mazzi")
print cur.getSchema()
for i in cur.fetch():
print i
生成以下错误:
回溯(最近一次调用last):文件“libra.py”,第10行,在cur.execute(“select*from glaquidara\u mazzi”)文件“/library/python/2.7/site packages/pyhs2/cursor.py”,第64行,在execute raise pyhs2exception(res.status.errorcode,res.status.errormessage)pyhs2.error.pyhs2exception:'编译语句时出错:failed:runtimeexception org.apache.hadoop.ipc.remoteexception:org.apache.hadoop.hdfs.server.namenode.safemodeexception:cannot create directory/tmp/hive root/hive\ u 2015-10-07\ u 13-32-30\ u 348\ u 38078262746902303- 3. Name node is in safe mode.\nResources are low on NN. Safe mode must be turned off manually.\n\tat org.apache.hadoop.hdfs.server.namenode.FSNamesystem.mkdirsInternal(FSNamesystem.java:2140)\n\tat org.apache.hadoop.hdfs.server.namenode.FSNamesystem.mkdirs(FSNamesystem.java:2114)\n\tat org.apache.hadoop.hdfs.server.namenode.NameNode.mkdirs(NameNode.java:892)\n\tat sun.reflect.GeneratedMethodAccessor586.invoke(Unknown Source)\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)\n\tat java.lang.reflect.Method.invoke(Method.java:597)\n\tat org.apache.hadoop.ipc.RPC$Server.call(RPC.java:557)\n\tat org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1439)\n\tat org.apache.hadoop.ipc.Server$Handler$1.run(Server.java:1435)\n\tat java.security.AccessController.doPrivileged(Native Method)\n\tat javax.security.auth.Subject.doAs(Subject.java:396)\n\tat org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1278)\n\tat org.apache.hadoop.ipc.Server$Handler.run(Server.java:1433)\n'
这有什么问题?
暂无答案!
目前还没有任何答案,快来回答吧!