JAkutenshi commented on code in PR #7196:
URL: https://github.com/apache/ignite-3/pull/7196#discussion_r2608554221
##########
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItOperationRetryTest.java:
##########
@@ -104,8 +110,47 @@ public void testLockExceptionRetry() {
assertEquals("new value", view.get(null, Tuple.create().set("key",
1)).value("val"));
}
- private IgniteImpl findNodeByName(String leaseholder) {
- return findNode(0, initialNodes(), n -> leaseholder.equals(n.name()));
+ @Test
+ public void retryImplicitTransactionsTest() throws InterruptedException {
+ IgniteImpl node0 = unwrapIgniteImpl(node(0));
+
+ ZonePartitionId partitionGroupId = extractPartitionGroupId(node0,
ZONE_NAME, PART_ID);
+
+ String leaseholderNodeName = waitAndGetPrimaryReplica(node0,
partitionGroupId).getLeaseholder();
+
+ IgniteImpl leaseholderNode = findNodeByName(leaseholderNodeName);
+
+ IgniteImpl transactionCoordinatorNode =
findNonLeaseholderNode(leaseholderNode);
+
+ IgniteImpl futureLeaseholderNode = findNodeByFilter(n -> {
+ String nodeName = n.name();
+
+ return !(nodeName.equals(leaseholderNode.name()) ||
nodeName.equals(transactionCoordinatorNode.name()));
+ });
+
+ DefaultMessagingService messagingService = (DefaultMessagingService)
leaseholderNode.clusterService().messagingService();
+ messagingService.dropMessages((nodeName, msg) -> msg instanceof
PrimaryReplicaRequest);
Review Comment:
I see now what did you mean, now I separated it on two cases: replication
timeout and replica missed.
--
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]
