@@ -2028,13 +2028,14 @@ public ObPair<Long, ObTableParam> getTableInternal(String tableName, TableEntry
20282028 boolean addrExpired = addr .isExpired (serverAddressCachingTimeout );
20292029 while ((obTable == null || addrExpired ) && retryTimes < 2 ) {
20302030 ++retryTimes ;
2031- if (addr . isExpired ( serverAddressCachingTimeout ) ) {
2031+ if (addrExpired ) {
20322032 logger .info ("Server addr {} is expired, refreshing tableEntry." , addr );
20332033 if (ObGlobal .obVsnMajor () >= 4 ) {
20342034 refreshTableLocationByTabletId (tableEntry , tableName , tabletId );
20352035 } else {
20362036 tableEntry = getOrRefreshTableEntry (tableName , true , waitForRefresh , false );
20372037 }
2038+ addrExpired = addr .isExpired (serverAddressCachingTimeout );
20382039 }
20392040 if (obTable == null ) {
20402041 // need to refresh table roster to ensure the current roster is the latest
@@ -2331,13 +2332,14 @@ private List<ObPair<Long, ObTableParam>> getTables(String tableName, ObTableQuer
23312332 boolean addrExpired = addr .isExpired (serverAddressCachingTimeout );
23322333 while ((obTable == null || addrExpired ) && retryTimes < 2 ) {
23332334 ++retryTimes ;
2334- if (addr . isExpired ( serverAddressCachingTimeout ) ) {
2335+ if (addrExpired ) {
23352336 logger .info ("Server addr {} is expired, refreshing tableEntry." , addr );
23362337 if (ObGlobal .obVsnMajor () >= 4 ) {
23372338 refreshTableLocationByTabletId (tableEntry , tableName , tabletId );
23382339 } else {
23392340 tableEntry = getOrRefreshTableEntry (tableName , true , waitForRefresh , false );
23402341 }
2342+ addrExpired = addr .isExpired (serverAddressCachingTimeout );
23412343 }
23422344 if (obTable == null ) {
23432345 // need to refresh table roster to ensure the current roster is the latest
0 commit comments