This is an automated email from the ASF dual-hosted git repository. nnag pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push: new 7f63c4b GEODE-5273: Prevent unnecessary chaining of exception. (#2012) 7f63c4b is described below commit 7f63c4b2faf0b623ecdcad485686938711204419 Author: Nabarun Nag <nabarun...@users.noreply.github.com> AuthorDate: Fri Jun 1 11:14:27 2018 -0700 GEODE-5273: Prevent unnecessary chaining of exception. (#2012) * ForceReattemptException is not wrapped in another ForceReattemptException. Co-authored-by: bijukunjummen <biju.kunjum...@gmail.com> --- .../geode/internal/cache/execute/FunctionStreamingResultCollector.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/FunctionStreamingResultCollector.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/FunctionStreamingResultCollector.java index 24935ac..a57eec8 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/FunctionStreamingResultCollector.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/FunctionStreamingResultCollector.java @@ -446,7 +446,8 @@ public class FunctionStreamingResultCollector extends ReplyProcessor21 implement } else if (t instanceof RegionDestroyedException) { throw (RegionDestroyedException) t; } else if (t instanceof ForceReattemptException) { - throw new ForceReattemptException("Peer requests reattempt", t); + logger.info("Peer requests reattempt"); + throw (ForceReattemptException) t; } else if (t instanceof PrimaryBucketException) { throw new PrimaryBucketException("Peer failed primary test", t); } -- To stop receiving notification emails like this one, please contact n...@apache.org.