pig DBStorage into mysql on EMR

sudo apt-get install libmysql-java

Pig script:

register /usr/share/java/mysql.jar

STORE results INTO ‘test’ using org.apache.pig.piggybank.storage.DBStorage(‘com.mysql.jdbc.Driver’, ‘jdbc:mysql://host_ip/database_name’, ‘username’, ‘password’, ‘INSERT INTO test (a,b,c,d) VALUES(?,?,?,?)’);

MySQL:

/etc/mysql/my.cnf (change bind-address to 0.0.0.0)

bind-address           = 0.0.0.0

sudo /etc/init.d/mysql restart

mysql -u root

INSERT INTO user (Host,User,Password) VALUES(‘%’,’username’,PASSWORD(‘password’));

GRANT ALL PRIVILEGES ON database_name.* To ‘username’@’%’ IDENTIFIED BY ‘password’;