chaijunjie0101 commented on code in PR #7117:
URL: https://github.com/apache/hbase/pull/7117#discussion_r2235865497
##########
hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncNonMetaRegionLocator.java:
##########
@@ -618,4 +635,60 @@ int getNumberOfCachedRegionLocations(TableName tableName) {
return tableCache.regionLocationCache.getAll().stream()
.mapToInt(RegionLocations::numNonNullElements).sum();
}
+
+ private TimerTask getInvalidateMetaCacheTask(long
metaCacheInvalidateInterval) {
+ return new TimerTask() {
+ @Override
+ public void run(Timeout timeout) throws Exception {
+ FutureUtils.addListener(invalidateTableCache(), (res, err) -> {
+ if (err != null) {
+ LOG.warn("InvalidateTableCache failed.", err);
+ }
+ AsyncConnectionImpl.RETRY_TIMER.newTimeout(this,
metaCacheInvalidateInterval,
+ TimeUnit.MILLISECONDS);
+ });
+ }
+ };
+ }
+
+ private CompletableFuture<Void> invalidateTableCache() {
+ CompletableFuture<Void> future = new CompletableFuture<>();
+ Iterator<TableName> tbnIter = cache.keySet().iterator();
+ AsyncAdmin admin = conn.getAdmin();
+ invalidateCache(future, tbnIter, admin);
+ return future;
+ }
+
+ private void invalidateCache(CompletableFuture<Void> future,
Iterator<TableName> tbnIter,
+ AsyncAdmin admin) {
+ if (tbnIter.hasNext()) {
+ TableName tableName = tbnIter.next();
+ FutureUtils.addListener(admin.isTableDisabled(tableName),
(tableDisabled, err) -> {
+ boolean shouldInvalidateCache = false;
+ if (err != null) {
+ if (err instanceof TableNotFoundException) {
+ LOG.info("Table {} was not exist, will invalidate it's cache.",
tableName);
Review Comment:
> it's -> its
modified it~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@hbase.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
