svn commit: r1516609 - in /hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test: IntegrationTestBigLinkedList.java IntegrationTestLoadAndVerify.java

[ec...@apache.org]

Author: eclark
Date: Thu Aug 22 21:15:30 2013
New Revision: 1516609

URL: http://svn.apache.org/r1516609
Log:
HBASE-9290 Add logging in IntegrationTestBigLinkedList Verify reduce phase

Modified:
    hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
    hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java

Modified: hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java?rev=1516609&r1=1516608&r2=1516609&view=diff
==============================================================================
--- hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java (original)
+++ hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java Thu Aug 22 21:15:30 2013
@@ -576,6 +576,8 @@ public class IntegrationTestBigLinkedLis
             refsSb.append(Bytes.toStringBinary(ref));
           }
           keyString = Bytes.toStringBinary(key.getBytes(), 0, key.getLength());
+
+          LOG.error("Linked List error: Key = " + keyString + " References = " + refsSb.toString());
         }
 
         if (defCount == 0 && refs.size() > 0) {

Modified: hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java?rev=1516609&r1=1516608&r2=1516609&view=diff
==============================================================================
--- hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java (original)
+++ hbase/trunk/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.java Thu Aug 22 21:15:30 2013
@@ -26,6 +26,8 @@ import java.util.regex.Pattern;
 
 import com.google.common.collect.Sets;
 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.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -239,6 +241,7 @@ public class IntegrationTestLoadAndVerif
   public static class VerifyMapper extends TableMapper<BytesWritable, BytesWritable> {
     static final BytesWritable EMPTY = new BytesWritable(HConstants.EMPTY_BYTE_ARRAY);
 
+
     @Override
     protected void map(ImmutableBytesWritable key, Result value, Context context)
         throws IOException, InterruptedException {
@@ -257,6 +260,7 @@ public class IntegrationTestLoadAndVerif
   }
 
   public static class VerifyReducer extends Reducer<BytesWritable, BytesWritable, Text, Text> {
+    private static final Log LOG = LogFactory.getLog(VerifyReducer.class);
     private Counter refsChecked;
     private Counter rowsWritten;
 
@@ -285,6 +289,7 @@ public class IntegrationTestLoadAndVerif
       if (!gotOriginalRow) {
         String parsedRow = makeRowReadable(referredRow.getBytes(), 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));
         rowsWritten.increment(1);
       }