HBASE-5491 Remove HBaseConfiguration.create() call from coprocessor.Exec class
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1295429 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
5bc6e3e4ec
commit
8eab15acf5
|
@ -52,7 +52,6 @@ import java.lang.reflect.Method;
|
||||||
* @see org.apache.hadoop.hbase.client.HTable#coprocessorExec(Class, byte[], byte[], org.apache.hadoop.hbase.client.coprocessor.Batch.Call, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback)
|
* @see org.apache.hadoop.hbase.client.HTable#coprocessorExec(Class, byte[], byte[], org.apache.hadoop.hbase.client.coprocessor.Batch.Call, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback)
|
||||||
*/
|
*/
|
||||||
public class Exec extends Invocation implements Row {
|
public class Exec extends Invocation implements Row {
|
||||||
private Configuration conf = HBaseConfiguration.create();
|
|
||||||
/** Row key used as a reference for any region lookups */
|
/** Row key used as a reference for any region lookups */
|
||||||
private byte[] referenceRow;
|
private byte[] referenceRow;
|
||||||
private Class<? extends CoprocessorProtocol> protocol;
|
private Class<? extends CoprocessorProtocol> protocol;
|
||||||
|
|
|
@ -26,6 +26,7 @@ import java.io.IOException;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import org.apache.hadoop.conf.Configuration;
|
import org.apache.hadoop.conf.Configuration;
|
||||||
|
import org.apache.hadoop.hbase.HBaseConfiguration;
|
||||||
import org.apache.hadoop.hbase.HBaseTestingUtility;
|
import org.apache.hadoop.hbase.HBaseTestingUtility;
|
||||||
import org.apache.hadoop.hbase.HConstants;
|
import org.apache.hadoop.hbase.HConstants;
|
||||||
import org.apache.hadoop.hbase.MediumTests;
|
import org.apache.hadoop.hbase.MediumTests;
|
||||||
|
@ -200,6 +201,7 @@ public class TestCoprocessorEndpoint {
|
||||||
dib.reset(dob.getData(), dob.getLength());
|
dib.reset(dob.getData(), dob.getLength());
|
||||||
|
|
||||||
Exec after = new Exec();
|
Exec after = new Exec();
|
||||||
|
after.setConf(HBaseConfiguration.create());
|
||||||
after.readFields(dib);
|
after.readFields(dib);
|
||||||
// no error thrown
|
// no error thrown
|
||||||
assertEquals(after.getProtocolName(), protocolName);
|
assertEquals(after.getProtocolName(), protocolName);
|
||||||
|
|
Loading…
Reference in New Issue