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

HBASE-9551: HBaseTestingUtility#createPreSplitLoadTestTable double close HBaseAdmin 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1524595 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
jeffreyz 2013-09-18 22:27:12 +00:00
parent 353016c99d
commit f56dbe50a5
4 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-client/src/main/java/org/apache/hadoop/hbase/client/HBaseAdmin.java
View File

@ -2377,9 +2377,10 @@ public class HBaseAdmin implements Abortable, Closeable {
}
@Override
public void close() throws IOException {
public synchronized void close() throws IOException {
if (cleanupConnectionOnClose && this.connection != null) {
this.connection.close();
this.connection = null;
}
}

1
hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java
View File

@ -3028,7 +3028,6 @@ public class HBaseTestingUtility extends HBaseCommonTestingUtility {
totalNumberOfRegions);
admin.createTable(desc, splits);
admin.close();
} catch (MasterNotRunningException e) {
LOG.error("Master not running", e);
throw new IOException(e);

3
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorEndpoint.java
View File

@ -287,7 +287,6 @@ public class TestCoprocessorEndpoint {
TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface service =
TestRpcServiceProtos.TestProtobufRpcProto.newBlockingStub(admin.coprocessorService());
assertEquals("hello", service.echo(null, request).getMessage());
admin.close();
}
@Test
@ -320,8 +319,6 @@ public class TestCoprocessorEndpoint {
service.error(null, TestProtos.EmptyRequestProto.getDefaultInstance());
fail("Should have thrown an exception");
} catch (ServiceException e) {
} finally {
admin.close();
}
}

1
hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/TestExportSnapshot.java
View File

@ -123,7 +123,6 @@ public class TestExportSnapshot {
TEST_UTIL.deleteTable(tableName);
SnapshotTestingUtils.deleteAllSnapshots(TEST_UTIL.getHBaseAdmin());
SnapshotTestingUtils.deleteArchiveDirectory(TEST_UTIL);
admin.close();
}
/**