Can you post the complete message ? What HBase version are you using ?
On Thu, May 17, 2012 at 4:48 PM, Something Something < [email protected]> wrote: > Hello, > > I keep getting this message while running the 'completebulkload' process. > I tried the following solutions that I came across while Googling for this > error: > > 1) setReduceSpeculativeExecution(true) > > 2) Made sure that none of the tasks are failing. > > 3) The HFileOutput job runs successfully. > > 4) The first 2 lines in the output from HFileOutput look like this: > > 2b 39 4c 39 39 2f 2b 2b 4d 57 54 37 66 32 2b 32 2a 31 2a 31 35 33 33 34 37 > 2a 34 39 39 39 row=+9L99/++MWT7f2+2*1*153347*4999, > families={(family=info, > > keyvalues=(+9L99/++MWT7f2+2*1*153347*4999/info:frequency/9223372036854775807/Put/vlen=1)} > 2b 39 4c 39 39 2f 2b 2b 4d 57 54 37 66 32 2b 32 2a 31 2a 31 35 33 33 34 38 > 2a 34 39 39 39 row=+9L99/++MWT7f2+2*1*153348*4999, > families={(family=info, > > keyvalues=(+9L99/++MWT7f2+2*1*153348*4999/info:frequency/9223372036854775807/Put/vlen=1)} > > > 5) My Mapper for HFileOutput looks like this: > > public static class MyMapper extends MapReduceBase implements > Mapper<LongWritable, Text, ImmutableBytesWritable, Put> { > > @Override > public void map(LongWritable key, Text value, > OutputCollector<ImmutableBytesWritable, Put> output, Reporter reporter) > throws IOException { > String[] values = value.toString().split("\t"); > String key1 = values[0]; > String value1 = values[1]; > > ImmutableBytesWritable ibw = new > ImmutableBytesWritable(key1.getBytes()); > Put put = new Put(Bytes.toBytes(key1)); > put.add(Bytes.toBytes("info"), Bytes.toBytes("frequency"), > Bytes.toBytes(value1)); > output.collect(ibw, put); > } > > } > > > Any ideas what could be wrong? Thanks for your help. >
