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

HBASE-22292 PreemptiveFastFailInterceptor clean repeatedFailuresMap issue 

Signed-off-by: stack <stack@apache.org>
This commit is contained in:
zouxiangwen 2019-04-23 22:56:59 +08:00 committed by stack
parent a31347fccc
commit 150f87797a
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-client/src/main/java/org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java
View File

@ -96,6 +96,9 @@ class PreemptiveFastFailInterceptor extends RetryingCallerInterceptor {
HConstants.HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS, HConstants.HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS,
HConstants.HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT); HConstants.HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT);
this.failureMapCleanupIntervalMilliSec = conf.getLong( this.failureMapCleanupIntervalMilliSec = conf.getLong(
HConstants.HBASE_CLIENT_FAILURE_MAP_CLEANUP_INTERVAL_MS,
HConstants.HBASE_CLIENT_FAILURE_MAP_CLEANUP_INTERVAL_MS_DEFAULT);
this.fastFailClearingTimeMilliSec = conf.getLong(
HConstants.HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS, HConstants.HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS,
HConstants.HBASE_CLIENT_FAST_FAIL_CLEANUP_DURATION_MS_DEFAULT); HConstants.HBASE_CLIENT_FAST_FAIL_CLEANUP_DURATION_MS_DEFAULT);
lastFailureMapCleanupTimeMilliSec = EnvironmentEdgeManager.currentTime(); lastFailureMapCleanupTimeMilliSec = EnvironmentEdgeManager.currentTime();

6
hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
View File

@ -1340,6 +1340,12 @@ public final class HConstants {
public static final long HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT = public static final long HBASE_CLIENT_FAST_FAIL_THREASHOLD_MS_DEFAULT =
60000; 60000;
public static final String HBASE_CLIENT_FAILURE_MAP_CLEANUP_INTERVAL_MS =
"hbase.client.failure.map.cleanup.interval";
public static final long HBASE_CLIENT_FAILURE_MAP_CLEANUP_INTERVAL_MS_DEFAULT =
600000;
public static final String HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS = public static final String HBASE_CLIENT_FAST_FAIL_CLEANUP_MS_DURATION_MS =
"hbase.client.fast.fail.cleanup.duration"; "hbase.client.fast.fail.cleanup.duration";