我在使用Sqoop将表从MySQL导入HBase时遇到问题.我在一个有3个节点的集群中工作(1个主节点,2个从节点).
当我尝试运行此命令时:
sqoop import --hbase-create-table --hbase-table (any_tablename)
--column-family (any_cf) --hbase-row-key (any_rowkey) --connect
jdbc:mysql://(mysqlserver_machine_IP)/(any_db) --username root -P --table (any_table)
-m 1
我收到以下错误:
...13/07/30 12:13:36 INFO zookeeper.ZooKeeper: Session: 0x1402df83cc5000a closed
13/07/30 12:13:36 INFO zookeeper.ClientCnxn: EventThread shut down
13/07/30 12:13:42 INFO mapred.JobClient: Running job: job_201307301159_0001
13/07/30 12:13:43 INFO mapred.JobClient: map 0% reduce 0%
13/07/30 12:28:12 INFO mapred.JobClient: Task Id : attempt_201307301159_0001_m_000000_0, Status : FAILED
java.lang.RuntimeException: Could not access HBase table mypop
at org.apache.sqoop.hbase.HBasePutProcessor.setConf(HBasePutProcessor.java:121)
at org.apache.hadoop.util.ReflectionUtils.setConf(ReflectionUtils.java:62)
at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:117)
at org.apache.sqoop.mapreduce.DelegatingOutputFormat$DelegatingRecordWriter.<init>(DelegatingOutputFormat.java:107)
at org.apache.sqoop.mapreduce.DelegatingOutputFormat.getRecordWriter(DelegatingOutputFormat.java:82)
at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.<init>(MapTask.java:628) …