From dd3b366b220208b28142d8a929e48f4aa333cbb4 Mon Sep 17 00:00:00 2001
From: chesnokoff <chesnokoff239@gmail.com>
Date: Sun, 21 Jun 2026 23:27:41 +0300
Subject: [PATCH] IGNITE-28805 Fix flaky
 ContinuousQueryMarshallerTest#testRemoteFilterFactoryServer

---
 .../cache/query/continuous/ContinuousQueryMarshallerTest.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/ContinuousQueryMarshallerTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/ContinuousQueryMarshallerTest.java
index dab32bb151485..9fb42a5fc8efd 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/ContinuousQueryMarshallerTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/ContinuousQueryMarshallerTest.java
@@ -83,6 +83,8 @@ private void check(String node1Name, String node2Name) throws Exception {
 
         final Ignite node2 = "client".equals(node2Name) ? startClientGrid(node2Name) : startGrid(node2Name);
 
+        awaitPartitionMapExchange();
+
         final ContinuousQuery<Integer, MarshallerCheckingEntry> qry = new ContinuousQuery<>();
 
         ScanQuery<Integer, MarshallerCheckingEntry> scanQry = new ScanQuery<>(new IgniteBiPredicate<Integer, MarshallerCheckingEntry>() {