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

HBASE-9367 TestRegionServerCoprocessorExceptionWithAbort.testExceptionFromCoprocessorDuringPut fails 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1518330 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-08-28 19:16:27 +00:00
parent 1e71b56731
commit 695c6269fc
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionServerCoprocessorExceptionWithAbort.java
View File

@ -21,7 +21,6 @@ package org.apache.hadoop.hbase.coprocessor;
import java.io.IOException; import java.io.IOException;
import junit.framework.Assert;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
@ -33,6 +32,7 @@ import org.apache.hadoop.hbase.regionserver.HRegionServer;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.regionserver.wal.WALEdit; import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
@ -49,6 +49,7 @@ import static org.junit.Assert.*;
public class TestRegionServerCoprocessorExceptionWithAbort { public class TestRegionServerCoprocessorExceptionWithAbort {
static final Log LOG = LogFactory.getLog(TestRegionServerCoprocessorExceptionWithAbort.class); static final Log LOG = LogFactory.getLog(TestRegionServerCoprocessorExceptionWithAbort.class);
private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(); private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
private static final byte[] ROW = Bytes.toBytes("aaa");
private static final TableName TABLE_NAME = private static final TableName TABLE_NAME =
TableName.valueOf("observed_table"); TableName.valueOf("observed_table");
@ -82,13 +83,12 @@ public class TestRegionServerCoprocessorExceptionWithAbort {
// Note which regionServer will abort (after put is attempted). // Note which regionServer will abort (after put is attempted).
final HRegionServer regionServer = TEST_UTIL.getRSForFirstRegionInTable(TEST_TABLE); final HRegionServer regionServer = TEST_UTIL.getRSForFirstRegionInTable(TEST_TABLE);
final byte[] ROW = Bytes.toBytes("aaa");
Put put = new Put(ROW); Put put = new Put(ROW);
put.add(TEST_FAMILY, ROW, ROW); put.add(TEST_FAMILY, ROW, ROW);
Assert.assertFalse("The region server should be available", regionServer.isAborted()); Assert.assertFalse("The region server should be available", regionServer.isAborted());
try { try {
LOG.info("Running put " + put);
table.put(put); table.put(put);
fail("The put should have failed, as the coprocessor is buggy"); fail("The put should have failed, as the coprocessor is buggy");
} catch (IOException ignored) { } catch (IOException ignored) {
@ -105,10 +105,9 @@ public class TestRegionServerCoprocessorExceptionWithAbort {
final Durability durability) { final Durability durability) {
TableName tableName = TableName tableName =
c.getEnvironment().getRegion().getRegionInfo().getTableName(); c.getEnvironment().getRegion().getRegionInfo().getTableName();
if (TABLE_NAME.equals(tableName)) { if (TABLE_NAME.equals(tableName) && Bytes.equals(put.getRow(), ROW)) {
throw new NullPointerException("Buggy coprocessor"); throw new NullPointerException("Buggy coprocessor: " + put);
} }
} }
} }
} }