Java程序是实现sqoop把数据从mysql数据库中导入hdfs中,但是报错了!
Java程序是实现sqoop把数据从mysql数据库中导入hdfs中,但是报错了!
12/11/20 16:18:18 WARN mapreduce.JobBase: SQOOP_HOME is unset. May not be able to find all job dependencies.
java.lang.NoSuchMethodError: org.apache.hadoop.ipc.RPC.getProxy(Ljava/lang/Class;JLjava/net/InetSocketAddress;Lorg/apache/hadoop/security/UserGroupInformation;Lorg/apache/hadoop/conf/Configuration;Ljavax/net/SocketFactory;)Ljava/lang/Object;
at org.apache.hadoop.mapred.JobClient.createRPCProxy(JobClient.java:520)
at org.apache.hadoop.mapred.JobClient.init(JobClient.java:505)
at org.apache.hadoop.mapred.JobClient.<init>(JobClient.java:476)
at org.apache.hadoop.mapreduce.Job$1.run(Job.java:544)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Unknown Source)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1115)
at org.apache.hadoop.mapreduce.Job.connect(Job.java:542)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:530)
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:561)
at com.cloudera.sqoop.mapreduce.ImportJobBase.runJob(ImportJobBase.java:107)
at com.cloudera.sqoop.mapreduce.ImportJobBase.runImport(ImportJobBase.java:166)
at com.cloudera.sqoop.manager.SqlManager.importTable(SqlManager.java:386)
at com.cloudera.sqoop.manager.MySQLManager.importTable(MySQLManager.java:125)
at com.cloudera.sqoop.tool.ImportTool.importTable(ImportTool.java:350)
at com.cloudera.sqoop.tool.ImportTool.run(ImportTool.java:423)
at com.cloudera.sqoop.Sqoop.run(Sqoop.java:144)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)
at com.cloudera.sqoop.Sqoop.runSqoop(Sqoop.java:180)
at com.cloudera.sqoop.Sqoop.runTool(Sqoop.java:218)
at com.cloudera.sqoop.Sqoop.main(Sqoop.java:228)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.apache.hadoop.util.ProgramDriver$ProgramDescription.invoke(ProgramDriver.java:68)
at org.apache.hadoop.util.ProgramDriver.driver(ProgramDriver.java:139)
at com.neusoft.iotic.collector.rmdb.RmdbJobExecutor.saveToHdfs(RmdbJobExecutor.java:110)
at com.neusoft.iotic.collector.rmdb.RmdbJobExecutor.main(RmdbJobExecutor.java:126)
怎么回事呢?要怎么解决?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
好像是jar包冲突了,已经换别的办法了!
是不是应该要配置下
SQOOP_HOME的环境变量