You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2017/08/18 21:53:09 UTC
geode git commit: GEODE-3055: Should use a conservative fix to only
catch the PartitionOfflineEx to remove the leader region bucket.
Repository: geode
Updated Branches:
refs/heads/feature/GEM-1601 [created] 291dac019
GEODE-3055: Should use a conservative fix to only catch the PartitionOfflineEx
to remove the leader region bucket.
Previous fix to catch all RuntimeException is too aggressive.
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/291dac01
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/291dac01
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/291dac01
Branch: refs/heads/feature/GEM-1601
Commit: 291dac019f534af41470f0ee709c47477395d6fb
Parents: f38dff9
Author: zhouxh <gz...@pivotal.io>
Authored: Fri Aug 18 14:51:31 2017 -0700
Committer: zhouxh <gz...@pivotal.io>
Committed: Fri Aug 18 14:51:31 2017 -0700
----------------------------------------------------------------------
.../apache/geode/internal/cache/PartitionedRegionDataStore.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/291dac01/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java
index 893ca6b..7b2da35 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java
@@ -21,6 +21,7 @@ import org.apache.geode.cache.Region.Entry;
import org.apache.geode.cache.execute.Function;
import org.apache.geode.cache.execute.FunctionException;
import org.apache.geode.cache.execute.ResultSender;
+import org.apache.geode.cache.persistence.PartitionOfflineException;
import org.apache.geode.cache.query.QueryInvalidException;
import org.apache.geode.cache.query.internal.QCompiler;
import org.apache.geode.cache.query.internal.index.IndexCreationData;
@@ -494,7 +495,7 @@ public class PartitionedRegionDataStore implements HasCachePerfStats {
return result;
- } catch (RuntimeException validationException) {
+ } catch (PartitionOfflineException validationException) {
// GEODE-3055
PartitionedRegion leader = ColocationHelper.getLeaderRegion(this.partitionedRegion);
boolean isLeader = leader.equals(this.partitionedRegion);