ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-6068 - Fixed invalid partition handling
Date Tue, 15 Aug 2017 16:15:54 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-6068 [created] ce1266232


IGNITE-6068 - Fixed invalid partition handling


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ce126623
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ce126623
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ce126623

Branch: refs/heads/ignite-6068
Commit: ce1266232af609b1e3f1da9bbba9c3caba388f5a
Parents: f3d3d1b
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Tue Aug 15 19:15:38 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Tue Aug 15 19:15:38 2017 +0300

----------------------------------------------------------------------
 .../processors/query/schema/SchemaIndexCacheVisitorImpl.java  | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/ce126623/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaIndexCacheVisitorImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaIndexCacheVisitorImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaIndexCacheVisitorImpl.java
index 3a445bf..4e50f64 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaIndexCacheVisitorImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/SchemaIndexCacheVisitorImpl.java
@@ -24,6 +24,7 @@ import org.apache.ignite.internal.processors.cache.GridCacheContext;
 import org.apache.ignite.internal.processors.cache.GridCacheEntryEx;
 import org.apache.ignite.internal.processors.cache.GridCacheEntryRemovedException;
 import org.apache.ignite.internal.processors.cache.KeyCacheObject;
+import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtInvalidPartitionException;
 import org.apache.ignite.internal.processors.cache.persistence.CacheDataRow;
 import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition;
 import org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter;
@@ -118,6 +119,9 @@ public class SchemaIndexCacheVisitorImpl implements SchemaIndexCacheVisitor
{
                 KeyCacheObject key = row.key();
 
                 processKey(key, row.link(), clo);
+
+                if (part.state() == RENTING)
+                    break;
             }
         }
         finally {
@@ -149,6 +153,9 @@ public class SchemaIndexCacheVisitorImpl implements SchemaIndexCacheVisitor
{
 
                 break;
             }
+            catch (GridDhtInvalidPartitionException ignore) {
+                break;
+            }
             catch (GridCacheEntryRemovedException ignored) {
                 // No-op.
             }


Mime
View raw message