You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by nn...@apache.org on 2018/06/01 18:14:31 UTC

[geode] branch develop updated: GEODE-5273: Prevent unnecessary chaining of exception. (#2012)

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 <na...@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 <bi...@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
nnag@apache.org.