Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-9290 Add logging in IntegrationTestBigLinkedList Verify reduce phase

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1516609 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
eclark 2013-08-22 21:15:30 +00:00
parent fa5e087ae9
commit de60f4999e
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
View File

@ -576,6 +576,8 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase {
refsSb.append(Bytes.toStringBinary(ref)); refsSb.append(Bytes.toStringBinary(ref));
} }
keyString = Bytes.toStringBinary(key.getBytes(), 0, key.getLength()); keyString = Bytes.toStringBinary(key.getBytes(), 0, key.getLength());
LOG.error("Linked List error: Key = " + keyString + " References = " + refsSb.toString());
} }
if (defCount == 0 && refs.size() > 0) { if (defCount == 0 && refs.size() > 0) {

5
hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java
View File

@ -26,6 +26,8 @@ import java.util.regex.Pattern;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.CommandLine;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
@ -239,6 +241,7 @@ public class IntegrationTestLoadAndVerify extends IntegrationTestBase {
public static class VerifyMapper extends TableMapper<BytesWritable, BytesWritable> { public static class VerifyMapper extends TableMapper<BytesWritable, BytesWritable> {
static final BytesWritable EMPTY = new BytesWritable(HConstants.EMPTY_BYTE_ARRAY); static final BytesWritable EMPTY = new BytesWritable(HConstants.EMPTY_BYTE_ARRAY);
@Override @Override
protected void map(ImmutableBytesWritable key, Result value, Context context) protected void map(ImmutableBytesWritable key, Result value, Context context)
throws IOException, InterruptedException { throws IOException, InterruptedException {
@ -257,6 +260,7 @@ public class IntegrationTestLoadAndVerify extends IntegrationTestBase {
} }
public static class VerifyReducer extends Reducer<BytesWritable, BytesWritable, Text, Text> { public static class VerifyReducer extends Reducer<BytesWritable, BytesWritable, Text, Text> {
private static final Log LOG = LogFactory.getLog(VerifyReducer.class);
private Counter refsChecked; private Counter refsChecked;
private Counter rowsWritten; private Counter rowsWritten;
@ -285,6 +289,7 @@ public class IntegrationTestLoadAndVerify extends IntegrationTestBase {
if (!gotOriginalRow) { if (!gotOriginalRow) {
String parsedRow = makeRowReadable(referredRow.getBytes(), referredRow.getLength()); String parsedRow = makeRowReadable(referredRow.getBytes(), referredRow.getLength());
String binRow = Bytes.toStringBinary(referredRow.getBytes(), 0, referredRow.getLength()); String binRow = Bytes.toStringBinary(referredRow.getBytes(), 0, referredRow.getLength());
LOG.error("Reference error row " + parsedRow);
ctx.write(new Text(binRow), new Text(parsedRow)); ctx.write(new Text(binRow), new Text(parsedRow));
rowsWritten.increment(1); rowsWritten.increment(1);
} }