AnsweredAssumed Answered

Importtsv complete bulk load data

Question asked by ravi0305 on Jun 15, 2014
Latest reply on Oct 26, 2017 by cathy
Hello,

I am trying to load data into hbase table. The data is in .csv file.
While  i am running the command
<code>

 $HADOOP_HOME/bin/hadoop jar $HBASE_HOME/lib/hbase-0.94.17-mapr-1405.jar importtsv -Dimporttsv.bulk.output=/user/hadoop/test6 -Dimporttsv.columns=HBASE_ROW_KEY,c:time,c:targettemp,c:actualtemp,c:system,c:systemage,c:buildingid  test2 s3://maprvertexcs/sample '-Dimporttsv.separator=,'

</code>
i am getting the below error
<pre>

14/06/16 11:35:42 INFO mapred.JobClient: Task Id : attempt_201406160545_0009_r_000000_0, Status : FAILED on node ip-172-31-1-117.us-west-2.compute.internal
java.io.IOException: java.lang.RuntimeException: Error occurred while instantiating com.mapr.fs.BulkLoadRecordWriter.
==> com.mapr.fs.BulkLoadRecordWriter.
        at org.apache.hadoop.hbase.client.mapr.GenericHFactory.handleIOException(GenericHFactory.java:62)
        at org.apache.hadoop.hbase.mapreduce.HFileOutputFormat.getRecordWriter(HFileOutputFormat.java:108)
        at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:589)
        at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:444)
        at org.apache.hadoop.mapred.Child$4.run(Child.java:270)
        at java.security.AccessController.doPrivileged(Native Method)
        at javax.security.auth.Subject.doAs(Subject.java:415)
        at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1127)
        at org.apache.hadoop.mapred.Child.main(Child.java:264)
Caused by: java.lang.RuntimeException: Error occurred while instantiating com.mapr.fs.BulkLoadRecordWriter.
==> com.mapr.fs.BulkLoadRecordWriter.
        at org.apache.hadoop.hbase.client.mapr.GenericHFactory.getImplementorInstance(GenericHFactory.java:40)
        at org.apache.hadoop.hbase.mapreduce.HFileOutputFormat.getRecordWriter(HFileOutputFormat.java:103)
        ... 7 more
Caused by: java.lang.ClassNotFoundException: com.mapr.fs.BulkLoadRecordWriter
        at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:190)
        at org.apache.hadoop.hbase.client.mapr.GenericHFactory.getImplementorInstance(GenericHFactory.java:30)
        ... 8 more
</pre>

 Please can anyone tell me why the error is coming.Please do the needful.

Regards,
Ravikanth

Outcomes