Skip to content

Commit 47edd9a

Browse files
committed
use flusherAndCompactor.onUpdate() and comment for backoff
1 parent 7e66d31 commit 47edd9a

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

hbase-server/src/main/java/org/apache/hadoop/hbase/master/region/MasterRegion.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,10 +171,14 @@ public void update(UpdateMasterRegion action) throws IOException {
171171
// for few times before aborting the active master. The master region might
172172
// have genuine case for delayed flushes and/or some procedure bug causing
173173
// heavy pressure on the memstore.
174+
flusherAndCompactor.onUpdate();
174175
if (tries == (maxRetriesForRegionUpdates - 1)) {
175176
abortServer(e);
176177
}
177178
LOG.info("Master region {} is too busy... retry attempt: {}", region, tries);
179+
// Exponential backoff is performed by ConnectionUtils.getPauseTime().
180+
// It uses HConstants.RETRY_BACKOFF array for the backoff multiplier, the
181+
// same array is used as backoff multiplier with RPC retries.
178182
Threads.sleep(ConnectionUtils.getPauseTime(regionUpdateRetryPauseTime, tries));
179183
} catch (IOException e) {
180184
// We catch IOException here to ensure that if the mutation is not successful

0 commit comments

Comments
 (0)