albertogpz commented on a change in pull request #6036:
URL: https://github.com/apache/geode/pull/6036#discussion_r696600959
##########
File path:
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java
##########
@@ -1892,9 +1908,10 @@ public void
testpersistentWanGateway_restartSender_expectAllEventsReceived_scena
LogWriterUtils.getLogWriter().info("All the senders are now running...");
//
----------------------------------------------------------------------------------------------------
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName(),
3000));
- vm3.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName(),
3000));
+ vm7.invoke(() -> WANTestBase.doPuts(getTestMethodName(), 500));
+ vm4.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName(),
3000));
+ vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName(), 500));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName(), 500));
Review comment:
I suggest that you leave the original test case as it is but starting
the gateway sender on vm7 without clean queues (there might be already a test
case testing it) and add this new modified test case which is equivalent to the
original one but starting the gateway sender with clean queues.
--
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]
