chesnokoff commented on code in PR #13265:
URL: https://github.com/apache/ignite/pull/13265#discussion_r3459838508
##########
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();
Review Comment:
Test started `server2` and immediately executed CQ with an initial scan
query. At this moment partition map exchange could still be in progress and the
initial scan sometimes did not see all existing entries.
In failed run the initial query returned only 2 entries instead of 5. Then
all update events arrived, but the latch was still not fully counted down and
the test failed with `AssertionError: 4`
The fix is to wait for pme after starting `server2` and before executing the
continuous query
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
