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

HBASE-14922 Delayed flush doesn't work causing flush storms. -- ADD

This commit is contained in:
Elliott Clark 2015-12-04 18:37:29 -08:00
parent cd5ddc5fec
commit 46198bb9a4
1 changed files with 3 additions and 0 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

@ -19,6 +19,8 @@
package org.apache.hadoop.hbase; package org.apache.hadoop.hbase;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.Delayed; import java.util.concurrent.Delayed;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
@ -34,6 +36,7 @@ import java.util.concurrent.TimeoutException;
* *
* This will spread out things on a distributed cluster. * This will spread out things on a distributed cluster.
*/ */
@InterfaceAudience.Private
public class JitterScheduledThreadPoolExecutorImpl extends ScheduledThreadPoolExecutor { public class JitterScheduledThreadPoolExecutorImpl extends ScheduledThreadPoolExecutor {
private final double spread; private final double spread;