phoenix-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ns G <nsgns...@gmail.com>
Subject Re: Pig - unable to read a Phoenix Table
Date Thu, 09 Jul 2015 17:44:06 GMT
Hi Ravi,

Here is the error I got

s = load 'hbase://table/ndm_17.table1/' using
org.apache.phoenix.pig.PhoenixHBaseLoader('regionserver');



ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1070: Could not resolve
org.apache.phoenix.pig.PhoenixHBaseLoader using imports: [, java.lang.,
org.apache.pig.builtin., org.apache.pig.impl.builtin.]

Thanks,
Dp
On 09-Jul-2015 10:47 pm, "Ravi Kiran" <maghamravikiran@gmail.com> wrote:

> Hi Durga,
>
> Can you share the errors you get when giving the LOAD the way i specified
> above. Also, can you confirm if the phoenix table is ndm_17.table1 and
> not NDM_17.TABLE1 ?
>
> Regards
> Ravi
>
> On Thu, Jul 9, 2015 at 10:09 AM, Ns G <nsgnsg84@gmail.com> wrote:
>
>> Hi Ravi Kiran,
>>
>> Thanks for your response. Yes I have tried the way you have suggested
>> already and still got failure message.
>>
>> We have 3 zookeeper and I have provided one in place of region server in
>> the above example and the null value  is what I got.
>>
>> Is there any other way I can test?
>>
>> Ps: I am able to load data using same jar and quorum.
>>
>> Thanks,
>>  On 09-Jul-2015 10:27 pm, "Ravi Kiran" <maghamravikiran@gmail.com> wrote:
>>
>>> Hi Durga,
>>>    Please refer the table name as below in the LOAD.
>>>
>>> s = load 'hbase://table/ndm_17.table1/' using org.apache.phoenix.pig.
>>> PhoenixHBaseLoader('regionserver');
>>>
>>> I am also hoping the 'regionserver' mentioned above is the zookeeper
>>> quorum.
>>>
>>> Regards
>>> Ravi
>>>
>>> On Thu, Jul 9, 2015 at 6:35 AM, Ns G <nsgnsg84@gmail.com> wrote:
>>>
>>>> Hi there,
>>>>
>>>> I am trying to read a phoenix table through pig but i am facing error
>>>> and unable to read. we are using Cloudera version of phoenix (4.3.1)
>>>>
>>>> I have given command like
>>>> register /home/satya/phoenix-4.3.1-client.jar;
>>>>
>>>> and then the PIG Command:
>>>>
>>>> s = load 'hbase://ndm_17.table1/' using
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader('regionserver');
>>>>
>>>> Below is the error i am getting:
>>>>
>>>>  ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200: null
>>>>
>>>> ERROR 1200: null
>>>>
>>>> Failed to parse: null
>>>>     at
>>>> org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:198)
>>>>     at org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1660)
>>>>     at org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1633)
>>>>     at org.apache.pig.PigServer.registerQuery(PigServer.java:587)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:1093)
>>>>     at
>>>> org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:501)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:198)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:173)
>>>>     at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
>>>>     at org.apache.pig.Main.run(Main.java:541)
>>>>     at org.apache.pig.Main.main(Main.java:156)
>>>>     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>>>>     at
>>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>>>>     at
>>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>>>>     at java.lang.reflect.Method.invoke(Method.java:606)
>>>>     at org.apache.hadoop.util.RunJar.run(RunJar.java:221)
>>>>     at org.apache.hadoop.util.RunJar.main(RunJar.java:136)
>>>> Caused by: java.lang.NullPointerException
>>>>     at
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader.initializePhoenixPigConfiguration(PhoenixHBaseLoader.java:146)
>>>>     at
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader.getSchema(PhoenixHBaseLoader.java:229)
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.getSchemaFromMetaData(LOLoad.java:175)
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.<init>(LOLoad.java:89)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanBuilder.buildLoadOp(LogicalPlanBuilder.java:853)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerator.java:3568)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1625)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGenerator.java:1102)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.java:560)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java:421)
>>>>     at
>>>> org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:188)
>>>>     ... 16 more
>>>>
>>>>
>>>>
>>>>
>>>> Some times i got this error (not sure when )
>>>>
>>>> Pig Stack Trace
>>>> ---------------
>>>> ERROR 2245: Cannot get schema from loadFunc
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader
>>>>
>>>> Failed to parse: Can not retrieve schema from loader
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader@69dfe150
>>>>     at
>>>> org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:198)
>>>>     at org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1660)
>>>>     at org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1633)
>>>>     at org.apache.pig.PigServer.registerQuery(PigServer.java:587)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:1093)
>>>>     at
>>>> org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:501)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:198)
>>>>     at
>>>> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:173)
>>>>     at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
>>>>     at org.apache.pig.Main.run(Main.java:541)
>>>>     at org.apache.pig.Main.main(Main.java:156)
>>>>     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>>>>     at
>>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>>>>     at
>>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>>>>     at java.lang.reflect.Method.invoke(Method.java:606)
>>>>     at org.apache.hadoop.util.RunJar.run(RunJar.java:221)
>>>>     at org.apache.hadoop.util.RunJar.main(RunJar.java:136)
>>>> Caused by: java.lang.RuntimeException: Can not retrieve schema from
>>>> loader org.apache.phoenix.pig.PhoenixHBaseLoader@69dfe150
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.<init>(LOLoad.java:91)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanBuilder.buildLoadOp(LogicalPlanBuilder.java:853)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerator.java:3568)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1625)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGenerator.java:1102)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.java:560)
>>>>     at
>>>> org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java:421)
>>>>     at
>>>> org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:188)
>>>>     ... 16 more
>>>> Caused by: org.apache.pig.impl.logicalLayer.FrontendException: ERROR
>>>> 2245: Cannot get schema from loadFunc
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.getSchemaFromMetaData(LOLoad.java:179)
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.<init>(LOLoad.java:89)
>>>>     ... 23 more
>>>> Caused by: java.io.IOException: java.sql.SQLException: ERROR 103
>>>> (08004): Unable to establish connection.
>>>>     at
>>>> org.apache.phoenix.pig.util.PhoenixPigSchemaUtil.getResourceSchema(PhoenixPigSchemaUtil.java:77)
>>>>     at
>>>> org.apache.phoenix.pig.PhoenixHBaseLoader.getSchema(PhoenixHBaseLoader.java:230)
>>>>     at
>>>> org.apache.pig.newplan.logical.relational.LOLoad.getSchemaFromMetaData(LOLoad.java:175)
>>>>     ... 24 more
>>>> Caused by: java.sql.SQLException: ERROR 103 (08004): Unable to
>>>> establish connection.
>>>>     at
>>>> org.apache.phoenix.exception.SQLExceptionCode$Factory$1.newException(SQLExceptionCode.java:362)
>>>>     at
>>>> org.apache.phoenix.exception.SQLExceptionInfo.buildException(SQLExceptionInfo.java:133)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl.openConnection(ConnectionQueryServicesImpl.java:282)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl.access$300(ConnectionQueryServicesImpl.java:166)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl$11.call(ConnectionQueryServicesImpl.java:1831)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl$11.call(ConnectionQueryServicesImpl.java:1810)
>>>>     at
>>>> org.apache.phoenix.util.PhoenixContextExecutor.call(PhoenixContextExecutor.java:77)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl.init(ConnectionQueryServicesImpl.java:1810)
>>>>     at
>>>> org.apache.phoenix.jdbc.PhoenixDriver.getConnectionQueryServices(PhoenixDriver.java:162)
>>>>     at
>>>> org.apache.phoenix.jdbc.PhoenixEmbeddedDriver.connect(PhoenixEmbeddedDriver.java:126)
>>>>     at
>>>> org.apache.phoenix.jdbc.PhoenixDriver.connect(PhoenixDriver.java:133)
>>>>     at java.sql.DriverManager.getConnection(DriverManager.java:571)
>>>>     at java.sql.DriverManager.getConnection(DriverManager.java:187)
>>>>     at
>>>> org.apache.phoenix.mapreduce.util.ConnectionUtil.getConnection(ConnectionUtil.java:54)
>>>>     at
>>>> org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil.getSelectColumnMetadataList(PhoenixConfigurationUtil.java:227)
>>>>     at
>>>> org.apache.phoenix.pig.util.PhoenixPigSchemaUtil.getResourceSchema(PhoenixPigSchemaUtil.java:62)
>>>>     ... 26 more
>>>> Caused by: java.io.IOException:
>>>> java.lang.reflect.InvocationTargetException
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:240)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionManager.createConnection(ConnectionManager.java:414)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionManager.createConnectionInternal(ConnectionManager.java:323)
>>>>     at
>>>> org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:144)
>>>>     at
>>>> org.apache.phoenix.query.HConnectionFactory$HConnectionFactoryImpl.createConnection(HConnectionFactory.java:47)
>>>>     at
>>>> org.apache.phoenix.query.ConnectionQueryServicesImpl.openConnection(ConnectionQueryServicesImpl.java:280)
>>>>     ... 39 more
>>>> Caused by: java.lang.reflect.InvocationTargetException
>>>>     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
>>>> Method)
>>>>     at
>>>> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
>>>>     at
>>>> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>>>>     at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:238)
>>>>     ... 44 more
>>>> Caused by: java.lang.UnsupportedOperationException: Unable to find
>>>> org.apache.hadoop.hbase.ipc.controller.ClientRpcControllerFactory
>>>>     at
>>>> org.apache.hadoop.hbase.util.ReflectionUtils.instantiateWithCustomCtor(ReflectionUtils.java:36)
>>>>     at
>>>> org.apache.hadoop.hbase.ipc.RpcControllerFactory.instantiate(RpcControllerFactory.java:58)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.createAsyncProcess(ConnectionManager.java:2317)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.<init>(ConnectionManager.java:688)
>>>>     at
>>>> org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.<init>(ConnectionManager.java:630)
>>>>     ... 49 more
>>>> Caused by: java.lang.ClassNotFoundException:
>>>> org.apache.hadoop.hbase.ipc.controller.ClientRpcControllerFactory
>>>>     at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>>>>     at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>>>>     at java.security.AccessController.doPrivileged(Native Method)
>>>>     at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>>>>     at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>>>>     at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
>>>>     at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>>>>     at java.lang.Class.forName0(Native Method)
>>>>     at java.lang.Class.forName(Class.java:190)
>>>>     at
>>>> org.apache.hadoop.hbase.util.ReflectionUtils.instantiateWithCustomCtor(ReflectionUtils.java:32)
>>>>     ... 53 more
>>>>
>>>>
>>>>
>>>> Thanks a lot in advance,
>>>> Durga Prasad
>>>>
>>>
>>>
>

Mime
View raw message