Cloudera Community
kotesh_banoth
user rank
Contributor

Will the data be replicated, once balance data is...

by Contributor in Support Questions
‎11-09-2017 10:47 AM
‎11-09-2017 10:47 AM
@Jay Kumar SenSharma kindly help. I had removed one data node from the cluster of five node. Now i am adding the new data node to the cluster. If i do balance data will the data will be replicated (Existing replication factor is 3)to my newly added Data Node. ... View more

Re: How to access hive from python

by Contributor in Support Questions
‎09-16-2017 06:49 AM
‎09-16-2017 06:49 AM
Thanks so much @Jay SenSharma. Still getting the error I have hive installed in server(172.16.0.XXX) Is the below one is the right way to connect the hive from python ? conn = hive.connect(host='172.16.0.XXX', port=10000, username='kotesh') Port 10000 is listening: telnet 172.16.0.XXX 10000 Trying 172.16.0.XXX... Connected to 172.16.0.XXX. Escape character is '^]'. ============================================================ I had installed python in different server(172.16.0.YYY) python code: from pyhive import hive conn = hive.connect(host='172.16.0.XXX', port=10000, username='kotesh') cursor = conn.cursor() cursor.execute("select * from bmdatalake.dl_his_viewhistory limit 10") for result in cursor.fetchall(): use_result(result) While executing getting the error as below: ... View more

Re: How to access hive from python

by Contributor in Support Questions
‎09-16-2017 05:18 AM
‎09-16-2017 05:18 AM
Dear @Jay SenSharma , i have the mentioned libraries [medwadmin@chtcuxhd05 pyhive]$ ls -lh /usr/lib64/libsasl* lrwxrwxrwx 1 root root 17 Jul 17 19:21 /usr/lib64/libsasl2.so -> libsasl2.so.3.0.0 lrwxrwxrwx. 1 root root 17 Sep 21 2016 /usr/lib64/libsasl2.so.3 -> libsasl2.so.3.0.0 -rwxr-xr-x. 1 root root 119K Feb 16 2016 /usr/lib64/libsasl2.so.3.0.0 Below is my sample python code(file name: pyhive-test.py) to access hive: Error while executing: python pyhive-test.py: ================== [medwadmin@chtcuxhd05 pyhive]$ python pyhive-test.py Could not connect to any of [('172.16.0.125', 10000)] Traceback (most recent call last): File "pyhive-test.py", line 15, in <module> conn = hive.connect(host='172.16.0.125', port=10000, auth='KERBEROS',kerberos_service_name='hive') File "/home/medwadmin/anaconda3/lib/python3.5/site-packages/pyhive/hive.py", line 65, in connect return Connection(*args, **kwargs) File "/home/medwadmin/anaconda3/lib/python3.5/site-packages/pyhive/hive.py", line 156, in __init__ self._transport.open() File "/home/medwadmin/anaconda3/lib/python3.5/site-packages/thrift_sasl/__init__.py", line 61, in open self._trans.open() File "/home/medwadmin/anaconda3/lib/python3.5/site-packages/thrift/transport/TSocket.py", line 113, in open raise TTransportException(TTransportException.NOT_OPEN, msg) thrift.transport.TTransport.TTransportException: Could not connect to any of [('172.16.0.125', 10000)] ... View more

Re: How to access hive from python

by Contributor in Support Questions
‎09-15-2017 09:24 AM
‎09-15-2017 09:24 AM
@Jay SenSharma Can you please help me in connecting hive through python. conda --version 4.3.25 python-error.png Below is my pyhive-test.py file from pyhive import hive conn = hive.Connection(host="192.168.1.100", port=10000, auth="KERBEROS", database="bmdatalake", kerberos_service_name= "hive") cursor = conn.cursor() cursor.execute("select * from dl_his_kotesh limit 10") for result in cursor.fetchall(): use_result(result) ... View more

How to access hive from python

by Contributor in Support Questions
‎09-15-2017 06:33 AM
‎09-15-2017 06:33 AM
I want to access the hive through python. What process should i follow. How can i install pyhive in HDP2.5 ... View more

Re: Both NameNodes are StandBy

by Contributor in Support Questions
‎06-08-2017 08:26 AM
‎06-08-2017 08:26 AM
i am also having the same issue... can you help me out ... View more

Re: Vertex did not succeed due to OWN_TASK_FAILURE...

by Contributor in Support Questions
‎06-07-2017 08:35 AM
‎06-07-2017 08:35 AM
I changed but still having the same error . ... View more

Re: Ambari server fails to start after upgrading f...

by Contributor in Support Questions
‎06-06-2017 12:08 PM
‎06-06-2017 12:08 PM
Thanks so much, steps followed: 1) psql ambari -U ambari -W -p 5432 2) pg_dump ambari -U ambari -W -p 5432 > ambari_bkup 3) Delete commands 4) ambari-server start ... View more

Ambari server fails to start after upgrading from ...

by Contributor in Support Questions
‎06-06-2017 08:45 AM
‎06-06-2017 08:45 AM
1) Error injecting constructor, org.apache.ambari.server.StackAccessException: Stack data, stackName=HDP, stackVersion=2.3, serviceName=ZEPPELIN at org.apache.ambari.server.state.ServiceImpl.<init>(ServiceImpl.java:150) while locating org.apache.ambari.server.state.Service annotated with interface com.google.inject.assistedinject.Assisted at org.apache.ambari.server.state.cluster.ClusterImpl.<init>(ClusterImpl.java:341) while locating org.apache.ambari.server.state.Cluster annotated with interface com.google.inject.assistedinject.Assisted at org.apache.ambari.server.state.cluster.ClustersImpl.loadClustersAndHosts(ClustersImpl.java:186) at org.apache.ambari.server.state.cluster.ClustersImpl.class(ClustersImpl.java:102) while locating org.apache.ambari.server.state.cluster.ClustersImpl while locating org.apache.ambari.server.state.Clusters for parameter 0 at org.apache.ambari.server.agent.HeartBeatHandler.<init>(HeartBeatHandler.java:161) at org.apache.ambari.server.agent.HeartBeatHandler.class(HeartBeatHandler.java:122) while locating org.apache.ambari.server.agent.HeartBeatHandler 1 error at com.google.inject.internal.InjectorImpl$4.get(InjectorImpl.java:987) at com.google.inject.internal.InjectorImpl.getInstance(InjectorImpl.java:1013) at org.apache.ambari.server.controller.AmbariServer.performStaticInjection(AmbariServer.java:885) at org.apache.ambari.server.controller.AmbariServer.run(AmbariServer.java:301) at org.apache.ambari.server.controller.AmbariServer.main(AmbariServer.java:1011) Caused by: org.apache.ambari.server.StackAccessException: Stack data, stackName=HDP, stackVersion=2.3, serviceName=ZEPPELIN at org.apache.ambari.server.api.services.AmbariMetaInfo.getService(AmbariMetaInfo.java:536) at org.apache.ambari.server.state.ServiceImpl.<init>(ServiceImpl.java:183) at com.google.inject.internal.cglib.reflect.$FastConstructor.newInstance(FastConstructor.java:40) at com.google.inject.internal.ProxyFactory$ProxyConstructor.newInstance(ProxyFactory.java:260) at com.google.inject.internal.ConstructorInjector.construct(ConstructorInjector.java:85) at com.google.inject.internal.ConstructorBindingImpl$Factory.get(ConstructorBindingImpl.java:254) at com.google.inject.internal.InjectorImpl$4$1.call(InjectorImpl.java:978) at com.google.inject.internal.InjectorImpl.callInContext(InjectorImpl.java:1031) at com.google.inject.internal.InjectorImpl$4.get(InjectorImpl.java:974) at com.google.inject.assistedinject.FactoryProvider2.invoke(FactoryProvider2.java:632) at com.sun.proxy.$Proxy15.createExisting(Unknown Source) at org.apache.ambari.server.state.cluster.ClusterImpl.loadServices(ClusterImpl.java:461) at org.apache.ambari.server.state.cluster.ClusterImpl.<init>(ClusterImpl.java:352) at com.google.inject.internal.cglib.reflect.$FastConstructor.newInstance(FastConstructor.java:40) : ... View more

Re: Vertex did not succeed due to OWN_TASK_FAILURE...

by Contributor in Support Questions
‎06-01-2017 12:34 PM
‎06-01-2017 12:34 PM
After changing also iam getting the same error. In five node cluster i had changed on one node and that to not through the master node. ... View more
Contact Me
Online
Offline
Last Visited
‎11-12-2019 04:16 AM
Community Statistics
Member Since ‎10-31-2016 08:52 AM
Last Visited ‎11-12-2019 04:16 AM
Posts 81
Kudos received 1