You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/09/28 13:23:06 UTC
hbase git commit: HBASE-21244 Skip persistence when retrying for
assignment related procedures
Repository: hbase
Updated Branches:
refs/heads/master 71be251ef -> d39ea25d4
HBASE-21244 Skip persistence when retrying for assignment related procedures
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/d39ea25d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d39ea25d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d39ea25d
Branch: refs/heads/master
Commit: d39ea25d444e64403fb397bfac82eccd1a83dfa1
Parents: 71be251
Author: zhangduo <zh...@apache.org>
Authored: Thu Sep 27 20:25:06 2018 +0800
Committer: zhangduo <zh...@apache.org>
Committed: Fri Sep 28 21:22:23 2018 +0800
----------------------------------------------------------------------
.../hadoop/hbase/master/assignment/TransitRegionStateProcedure.java | 1 +
.../hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java | 1 +
2 files changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/d39ea25d/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java
index f6d22fa..dd8415a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java
@@ -329,6 +329,7 @@ public class TransitRegionStateProcedure
backoff / 1000, this, regionNode.toShortString(), e);
setTimeout(Math.toIntExact(backoff));
setState(ProcedureProtos.ProcedureState.WAITING_TIMEOUT);
+ skipPersistence();
throw new ProcedureSuspendedException();
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/d39ea25d/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java
index 24b1e5c..5b36f30 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ReopenTableRegionsProcedure.java
@@ -122,6 +122,7 @@ public class ReopenTableRegionsProcedure
regions.size(), tableName, backoff / 1000);
setTimeout(Math.toIntExact(backoff));
setState(ProcedureProtos.ProcedureState.WAITING_TIMEOUT);
+ skipPersistence();
throw new ProcedureSuspendedException();
default:
throw new UnsupportedOperationException("unhandled state=" + state);