2
누구든지이 문제를 해결할 수 있습니까? 돼지 결과를 mysql로 내보내려고하지만 사용자가 거부 한 액세스 문제가 있습니다. 사용자 이름과 비밀번호가 정확합니다.SQLException. mysql로 내보낼 때 PIG에 JDBC 오류가 발생했습니다.
Pig Stack Trace
---------------
ERROR 2997: Encountered IOException. JDBC Error
java.io.IOException: JDBC Error
at org.apache.pig.piggybank.storage.DBStorage.prepareToWrite(DBStorage.java:298)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat$PigRecordWriter.<init>(PigOutputFormat.java:125)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.getRecordWriter(PigOutputFormat.java:86)
at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:597)
at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:444)
at org.apache.hadoop.mapred.Child$4.run(Child.java:268)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1408)
at org.apache.hadoop.mapred.Child.main(Child.java:262)
Caused by: java.sql.SQLException: Access denied for user 'root'@'localhost' (using password: YES)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2975)
이 내 MySQL의 상태입니다 :이 로그 파일에서 오류가
REGISTER 'hdfs:///home/mysql-connector-java-3.1.14-bin.jar';
REGISTER 'hdfs:///home/piggybank-0.12.0.jar';
test = LOAD '/home/data.csv' USING PigStorage(',') AS (nom1:chararray, nom2:chararray, nom3:float, nom4:chararray);
processedtest = FOREACH test GENERATE nom1, nom2, nom3, nom4;
STORE processedtest INTO 'table' USING org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver', 'jdbc:mysql://localhost/test', 'root', 'root', 'INSERT INTO table (nom1, nom2, nom3, nom4) VALUES (?, ?, ?, ?)');
:
이
내 돼지 스크립트입니다 난 당신이 내가에 암호 '루트'를 사용 드릴 수 있습니다 액세스 :저는 아직 초보자입니다. mysql로 내보내기.