GEODE-233: Don't log a warning about a RegionDestroyedException The ParallelBucketOperator was logging a RegionDestroyedException during shutdown on region destruction. This is unnecessary noise from the background thread. The actual user thread will get this exception because PartitionedRegionRebalanceOperation checks for a destroyed region after each rebalancing step.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/e0407503 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/e0407503 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/e0407503 Branch: refs/heads/feature/GEODE-12 Commit: e04075034a7944acdb49478c01b27d5f956e72ba Parents: c3695aa Author: Dan Smith <[email protected]> Authored: Wed Aug 26 17:32:31 2015 -0700 Committer: Dan Smith <[email protected]> Committed: Wed Aug 26 17:32:31 2015 -0700 ---------------------------------------------------------------------- .../cache/partitioned/rebalance/ParallelBucketOperator.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0407503/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/ParallelBucketOperator.java ---------------------------------------------------------------------- diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/ParallelBucketOperator.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/ParallelBucketOperator.java index acea21a..b5094df 100644 --- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/ParallelBucketOperator.java +++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/ParallelBucketOperator.java @@ -6,6 +6,8 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; +import com.gemstone.gemfire.CancelException; +import com.gemstone.gemfire.cache.RegionDestroyedException; import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; /** @@ -78,6 +80,10 @@ public class ParallelBucketOperator implements BucketOperator { pendingFailure.add(completion); } }); + } catch(CancelException e) { + //ignore + } catch(RegionDestroyedException e) { + //ignore } finally { operationSemaphore.release(); }
