mysql - Pig STORE 到 MySQL 数据库 - ClassNotFoundException : 'com.mysql.jdbc.Driver'

Question

我正在使用 Pig，并尝试将结果存储在 MySQL 数据库中。根据我在此网站上找到的帮助，我正在使用:

STORE final_data INTO '$dbTable' USING org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://$host:$port/$db','$dbUser','$dbPass','INSERT INTO $dbTable');

我还导入了 jars(目录是正确的):Piggybank.jar，mysql-connector-java-5.1.20-bin.jar

但是，当我运行 Pig 脚本时，出现以下错误:

[MainThread] ERROR org.apache.pig.piggybank.storage.DBStorage - can't
load DB driver:com.mysql.djbc.Driver

java.lang.ClassNotFoundException: com.mysql.jdbc.Driver


[MainThread] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 2999:
Unexpected internal error. could not instantiate
'org.apache.pig.piggybank.storage.DBStorage' with arguments
'[com.mysql.jdbc.Driver, jdbc:mysql://x.xxx.xxx.xxx:xxxx/database,
username, password, INSERT INTO myTable]'

有人发现代码有错误吗？或者，也许我缺少一个 jar ？如果您对如何在 MySQL 数据库中存储 Pig 数据有其他建议，我也很想听听。

Answer 1

Try to add mysql-connector-java to the PIG_CLASSPATH

谢谢，这正是我需要做的!显然，仅进行 REGISTER 还不够。