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

Revert "HBASE-1422 Delayed flush doesn't work causing flush storms; addendum by Lars Hofhansl" 

Pushed with wrong JIRA number. Revert to fix.

This reverts commit 7d0c08fbcd.
This commit is contained in:
stack 2015-12-05 14:29:12 -08:00
parent 7d0c08fbcd
commit 693e1dee4c
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-common/src/main/java/org/apache/hadoop/hbase/JitterScheduledThreadPoolExecutorImpl.java
View File

@ -81,8 +81,7 @@ public class JitterScheduledThreadPoolExecutorImpl extends ScheduledThreadPoolEx
public long getDelay(TimeUnit unit) { public long getDelay(TimeUnit unit) {
long baseDelay = wrapped.getDelay(unit); long baseDelay = wrapped.getDelay(unit);
long spreadTime = (long) (baseDelay * spread); long spreadTime = (long) (baseDelay * spread);
long delay = spreadTime <= 0 ? baseDelay long delay = baseDelay + ThreadLocalRandom.current().nextLong(-spreadTime, spreadTime);
: baseDelay + ThreadLocalRandom.current().nextLong(-spreadTime, spreadTime);
// Ensure that we don't roll over for nanoseconds. // Ensure that we don't roll over for nanoseconds.
return (delay < 0) ? baseDelay : delay; return (delay < 0) ? baseDelay : delay;
} }