[
https://issues.apache.org/jira/browse/HBASE-29401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaijunjie updated HBASE-29401:
-------------------------------
Description:
There are one senior:
we have 2 apps to read/write HBase tables for a long time...
we could condisder as APP1 and APP2
APP1 create a new HBase table everyday, and write some data to it, then never
write/read it, it is just a daily-table(temporary table)...
APP2 will drop old table(before 30 days)....
Then the metaCache in APP1's conn, will contains too many old tables's region
locations...even never clear these after the table dropped...only when we
create a new hbase conn, will decrease memory used...
when we drop table using another conn(APP), will cause memleak on other APP's
metacache...
we could not to control to invalidate meta cache when some tables never visit
again...
I add this test to TestMetaCache.java to reproduce it
{code:java}
@Test
public void test2Apps() throws Throwable {
TableName tableName = TableName.valueOf("test2Apps");
ColumnFamilyDescriptor cf =
ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("cf")).build();
TableDescriptor tbn =
TableDescriptorBuilder.newBuilder(tableName).setColumnFamily(cf).build();
try (ConnectionImplementation conn1 = (ConnectionImplementation)
ConnectionFactory.createConnection(
TEST_UTIL.getConfiguration());
ConnectionImplementation conn2 = (ConnectionImplementation)
ConnectionFactory.createConnection(
TEST_UTIL.getConfiguration());) {
try (Admin admin1 = conn1.getAdmin()) {
admin1.createTable(tbn);
conn1.getRegionLocator(tableName).getAllRegionLocations();
Assert.assertEquals(1,
conn1.getNumberOfCachedRegionLocations(tableName));
}
try (Admin admin2 = conn2.getAdmin()) {
admin2.disableTable(tableName);
admin2.deleteTable(tableName);
conn2.getRegionLocator(tableName).getAllRegionLocations();
Assert.assertEquals(0,
conn2.getNumberOfCachedRegionLocations(tableName));
}
Assert.assertEquals(1,
conn1.getNumberOfCachedRegionLocations(tableName));
}
}
{code}
was:
There are one senior:
we have 2 apps to read/write HBase tables for a long time...
we could condisder as APP1 and APP2
APP1 create a new HBase table everyday, and write some data to it, then never
write/read it, it is just a daily-table(temporary table)...
APP2 will drop old table(before 30 days)....
Then the metaCache in APP1's conn, will contains too many old tables's region
locations...even never clear these after the table dropped...only when we
create a new hbase conn, will decrease memory used...
when we drop table using another conn(APP), will cause memleak on other APP's
metacache...
we could not to control to invalidate meta cache when some tables never visit
again...
> Support invalidate meta cache when some tables never visit again
> ----------------------------------------------------------------
>
> Key: HBASE-29401
> URL: https://issues.apache.org/jira/browse/HBASE-29401
> Project: HBase
> Issue Type: Improvement
> Components: meta
> Reporter: chaijunjie
> Priority: Major
>
> There are one senior:
> we have 2 apps to read/write HBase tables for a long time...
> we could condisder as APP1 and APP2
> APP1 create a new HBase table everyday, and write some data to it, then
> never write/read it, it is just a daily-table(temporary table)...
> APP2 will drop old table(before 30 days)....
> Then the metaCache in APP1's conn, will contains too many old tables's region
> locations...even never clear these after the table dropped...only when we
> create a new hbase conn, will decrease memory used...
> when we drop table using another conn(APP), will cause memleak on other APP's
> metacache...
> we could not to control to invalidate meta cache when some tables never visit
> again...
> I add this test to TestMetaCache.java to reproduce it
> {code:java}
> @Test
> public void test2Apps() throws Throwable {
> TableName tableName = TableName.valueOf("test2Apps");
> ColumnFamilyDescriptor cf =
> ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("cf")).build();
> TableDescriptor tbn =
> TableDescriptorBuilder.newBuilder(tableName).setColumnFamily(cf).build();
> try (ConnectionImplementation conn1 = (ConnectionImplementation)
> ConnectionFactory.createConnection(
> TEST_UTIL.getConfiguration());
> ConnectionImplementation conn2 = (ConnectionImplementation)
> ConnectionFactory.createConnection(
> TEST_UTIL.getConfiguration());) {
> try (Admin admin1 = conn1.getAdmin()) {
> admin1.createTable(tbn);
> conn1.getRegionLocator(tableName).getAllRegionLocations();
> Assert.assertEquals(1,
> conn1.getNumberOfCachedRegionLocations(tableName));
> }
> try (Admin admin2 = conn2.getAdmin()) {
> admin2.disableTable(tableName);
> admin2.deleteTable(tableName);
> conn2.getRegionLocator(tableName).getAllRegionLocations();
> Assert.assertEquals(0,
> conn2.getNumberOfCachedRegionLocations(tableName));
> }
> Assert.assertEquals(1,
> conn1.getNumberOfCachedRegionLocations(tableName));
> }
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
