| commit | 170ff5e18376a2f4ec5121ee5d536a9658e2333d | [log] [tgz] |
|---|---|---|
| author | Maksim Timonin <timonin.maxim@gmail.com> | Tue Aug 16 14:10:11 2022 +0300 |
| committer | GitHub <noreply@github.com> | Tue Aug 16 14:10:11 2022 +0300 |
| tree | 95f2a6f6390db733e23e5bb980e59a90c172ad6a | |
| parent | 4728d01995ed95357844361cba5668fcd3a4c2df [diff] |
IGNITE-17526 Fix checking stream in distributed cache query future (#10197)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java index 4a1e48c..46ba4fb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryFuture.java
@@ -141,9 +141,9 @@ /** {@inheritDoc} */ @Override protected void onNodeLeft(UUID nodeId) { - boolean hasRemotePages = streams.get(nodeId).hasRemotePages(); + NodePageStream<R> stream = streams.get(nodeId); - if (hasRemotePages) + if (stream != null && stream.hasRemotePages()) onError(new ClusterTopologyCheckedException("Remote node has left topology: " + nodeId)); }