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" <[email protected]> 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 <[email protected]> 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 >> > >
