You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kh...@apache.org on 2017/03/17 20:10:44 UTC
[09/49] geode git commit: GEODE-2618: PrimaryBucketExceptions handled
in LuceneQueryFunction.execute
GEODE-2618: PrimaryBucketExceptions handled in LuceneQueryFunction.execute
* PrimaryBucketException while executing a LuceneQuery will now be caught and wrapped as a InternalFunctionInvocationTargetException
* This will trigger a re-execution of the LuceneQuery on the member which will have the primary bucket.
This closes #416
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/88fa1aff
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/88fa1aff
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/88fa1aff
Branch: refs/heads/feature/GEODE-2420
Commit: 88fa1aff274aad73b505093a6d172439424c818b
Parents: de724d3
Author: nabarun <nn...@pivotal.io>
Authored: Tue Mar 7 14:55:54 2017 -0800
Committer: Ken Howe <kh...@pivotal.io>
Committed: Fri Mar 17 13:09:44 2017 -0700
----------------------------------------------------------------------
.../cache/lucene/internal/distributed/LuceneQueryFunction.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/88fa1aff/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/LuceneQueryFunction.java
----------------------------------------------------------------------
diff --git a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/LuceneQueryFunction.java b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/LuceneQueryFunction.java
index e3b5297..428301f 100644
--- a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/LuceneQueryFunction.java
+++ b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/LuceneQueryFunction.java
@@ -23,6 +23,7 @@ import org.apache.geode.cache.CacheClosedException;
import org.apache.geode.cache.execute.Function;
import org.apache.geode.cache.lucene.internal.LuceneIndexImpl;
import org.apache.geode.cache.lucene.internal.LuceneIndexStats;
+import org.apache.geode.internal.cache.PrimaryBucketException;
import org.apache.geode.internal.cache.execute.InternalFunctionInvocationTargetException;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.search.Query;
@@ -112,7 +113,8 @@ public class LuceneQueryFunction implements Function, InternalEntity {
}
stats.incNumberOfQueryExecuted();
resultSender.lastResult(mergedResult);
- } catch (IOException | BucketNotFoundException | CacheClosedException e) {
+ } catch (IOException | BucketNotFoundException | CacheClosedException
+ | PrimaryBucketException e) {
logger.debug("Exception during lucene query function", e);
throw new InternalFunctionInvocationTargetException(e);
}