Hi,
I am running a job to write some data from a HDFS file to and Hbase table using
the new API.
The job runs fine without any errors, but I do not see the rows added to the
hbase table.
This is what my code looks like -
I am running this as hadoop jar <jar_file_name> <class_name> <hdfs_file_name>
private HTable table;
protected void map(ImmutableBytesWritable key, Text value,
Context context)
throws IOException, InterruptedException
{
table = new HTable( new HBaseConfiguration(),
"blogposts");
// Split input line on tab character
String [] splits = value.toString().split("\t");
String rowID = splits[0];
String cellValue = splits[1];
Put p = new Put(Bytes.toBytes(rowID));
p.add(Bytes.toBytes("post"), Bytes.toBytes("title"),
Bytes.toBytes(splits[1]));
table.put(p);
table.flushCommits();
}
/*
This commented code when run seprataely in a main program runs fine and
does update to the table
HTable table = new HTable(new HBaseConfiguration(), "blogposts");
Put p = new Put(Bytes.toBytes("post3"));
p.add(Bytes.toBytes("post"), Bytes.toBytes("title"),
Bytes.toBytes("abx"));
p.add(Bytes.toBytes("post"), Bytes.toBytes("author"),
Bytes.toBytes("hadings"));
p.add(Bytes.toBytes("image"), Bytes.toBytes("body"),
Bytes.toBytes("123.jpg"));
p.add(Bytes.toBytes("image"), Bytes.toBytes("header"),
Bytes.toBytes("7657.jpg"));
table.put(p);
*/
Run log
10/06/16 19:00:35 WARN mapred.JobClient: Use GenericOptionsParser for parsing
the arguments. Applications should implement Tool for the same.
10/06/16 19:00:35 INFO input.FileInputFormat: Total input paths to process : 1
10/06/16 19:00:36 INFO mapred.JobClient: Running job: job_201003301510_0157
10/06/16 19:00:37 INFO mapred.JobClient: map 0% reduce 0%
10/06/16 19:00:45 INFO mapred.JobClient: map 100% reduce 0%
10/06/16 19:00:47 INFO mapred.JobClient: Job complete: job_201003301510_0157
10/06/16 19:00:47 INFO mapred.JobClient: Counters: 5
10/06/16 19:00:47 INFO mapred.JobClient: Job Counters
10/06/16 19:00:47 INFO mapred.JobClient: Rack-local map tasks=1
10/06/16 19:00:47 INFO mapred.JobClient: Launched map tasks=1
10/06/16 19:00:47 INFO mapred.JobClient: FileSystemCounters
10/06/16 19:00:47 INFO mapred.JobClient: HDFS_BYTES_READ=31
10/06/16 19:00:47 INFO mapred.JobClient: Map-Reduce Framework
10/06/16 19:00:47 INFO mapred.JobClient: Map input records=2
10/06/16 19:00:47 INFO mapred.JobClient: Spilled Records=0
Thanks,
Avani