(ignite) branch master updated: IGNITE-28804 Fix flaky GridCacheContinuousQueryMultiNodesFilteringTest#testWithNodeFilter (#13261)

[alexpl]

This is an automated email from the ASF dual-hosted git repository.

alex-plekhanov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new d25348c7697 IGNITE-28804 Fix flaky 
GridCacheContinuousQueryMultiNodesFilteringTest#testWithNodeFilter (#13261)
d25348c7697 is described below

commit d25348c769702b0a860691af84a1eef1e6b8c4c7
Author: Aleksandr Chesnokov <chesnokoff...@gmail.com>
AuthorDate: Mon Jun 22 15:28:42 2026 +0300

    IGNITE-28804 Fix flaky 
GridCacheContinuousQueryMultiNodesFilteringTest#testWithNodeFilter (#13261)
---
 .../continuous/GridCacheContinuousQueryMultiNodesFilteringTest.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryMultiNodesFilteringTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryMultiNodesFilteringTest.java
index f674dc8d157..9a7097a396e 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryMultiNodesFilteringTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryMultiNodesFilteringTest.java
@@ -58,6 +58,7 @@ import static 
org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
 import static org.apache.ignite.cache.CacheMode.PARTITIONED;
 import static org.apache.ignite.cache.CacheMode.REPLICATED;
 import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
+import static 
org.apache.ignite.internal.IgniteNodeAttributes.ATTR_IGNITE_INSTANCE_NAME;
 
 /** */
 @SuppressWarnings("unchecked")
@@ -176,7 +177,7 @@ public class 
GridCacheContinuousQueryMultiNodesFilteringTest extends GridCommonA
                     }
 
                     if (!set.add(e.getValue()))
-                        doubleNtfFail.set(false);
+                        doubleNtfFail.set(true);
                 }
             }
         };
@@ -419,7 +420,7 @@ public class 
GridCacheContinuousQueryMultiNodesFilteringTest extends GridCommonA
 
         /** {@inheritDoc} */
         @Override public boolean apply(ClusterNode clusterNode) {
-            return pattern.matcher(clusterNode.id().toString()).matches();
+            return 
pattern.matcher(clusterNode.attribute(ATTR_IGNITE_INSTANCE_NAME)).matches();
         }
     }
 }