----JAR所在的目錄
hadoop@hadoop-master:~$ pwd
/home/hadoop
hadoop@hadoop-master:~$ ls piggybank.jar mysql-connector-java-5.1.24-bin.jar
mysql-connector-java-5.1.24-bin.jar piggybank.jar
----腳本
register '/home/hadoop/mysql-connector-java-5.1.24-bin.jar';
register '/home/hadoop/piggybank.jar';
alldata = load '/neuhospital/mysql/201508111230/kce1_test/part-m-00000' using PigStorage(' ') ;
insertdata = foreach alldata generate $6;
store insertdata into 'test' USING org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://192.168.162.231:3306/warehouse','hive','hive','insert into patient_info_t(MedicalCareID) values (?)');
----報錯資訊
Pig Stack Trace
---------------
ERROR 1200: Pig script failed to parse:
<line 4, column 0> pig script failed to validate: java.lang.RuntimeException: could not instantiate 'org.apache.pig.piggyba
nk.storage.DBStorage' with arguments '[com.mysql.jdbc.Driver, jdbc:mysql://192.168.162.231:3306/warehouse, hive, hive, insert into patient_info_t(MedicalCareID) values (?)]'
Failed to parse: Pig script failed to parse:
<line 4, column 0> pig script failed to validate: java.lang.RuntimeException: could not instantiate 'org.apache.pig.piggyba
nk.storage.DBStorage' with arguments '[com.mysql.jdbc.Driver, jdbc:mysql://192.168.162.231:3306/warehouse, hive, hive, insert into patient_info_t(MedicalCareID) values (?)]'
at org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:199)
at org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1707)
at org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1680)
at org.apache.pig.PigServer.registerQuery(PigServer.java:623)
at org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:1082)
at org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:505)
at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:230)
at org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:205)
at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:66)
at org.apache.pig.Main.run(Main.java:565)
at org.apache.pig.Main.main(Main.java:177)
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:
<line 4, column 0> pig script failed to validate: java.lang.RuntimeException: could not instantiate 'org.apache.pig.piggyba
nk.storage.DBStorage' with arguments '[com.mysql.jdbc.Driver, jdbc:mysql://192.168.162.231:3306/warehouse, hive, hive, insert into patient_info_t(MedicalCareID) values (?)]'
at org.apache.pig.parser.LogicalPlanBuilder.buildStoreOp(LogicalPlanBuilder.java:1009)
at org.apache.pig.parser.LogicalPlanGenerator.store_clause(LogicalPlanGenerator.java:7806)
at org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1669)
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:191)
... 16 more
Caused by: java.lang.RuntimeException: could not instantiate 'org.apache.pig.piggybank.storage.DBStorage' with arguments '[com.mysql.jdbc.Driver, jdbc:mysql://192.168.162.231:3306/warehouse, hive, hive, insert into patient_info_t(MedicalCareID) values (?)]'
at org.apache.pig.impl.PigContext.instantiateFuncFromSpec(PigContext.java:772)
at org.apache.pig.parser.LogicalPlanBuilder.buildStoreOp(LogicalPlanBuilder.java:988)
... 22 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.pig.impl.PigContext.instantiateFuncFromSpec(PigContext.java:740)
... 23 more
Caused by: java.lang.RuntimeException: Can't load DB Driver
at org.apache.pig.piggybank.storage.DBStorage.<init>(DBStorage.java:82)
at org.apache.pig.piggybank.storage.DBStorage.<init>(DBStorage.java:71)
... 28 more
Caused by: java.lang.ClassNotFoundException: com.mysql.jdbc.Driver
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:191)
at org.apache.pig.piggybank.storage.DBStorage.<init>(DBStorage.java:79)
... 29 more
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/88595.html
標籤：云存儲